@rewaa/event-broker
Advanced tools
Comparing version
@@ -148,3 +148,3 @@ "use strict"; | ||
for (let i = 0; i < queues.length; i += constants_1.TAG_QUEUE_CHUNK_SIZE) { | ||
const queueChunk = queues.slice(i, i + constants_1.TOPIC_SUBSCRIBE_CHUNK_SIZE); | ||
const queueChunk = queues.slice(i, i + constants_1.TAG_QUEUE_CHUNK_SIZE); | ||
const promises = []; | ||
@@ -151,0 +151,0 @@ for (const queue of queueChunk) { |
{ | ||
"name": "@rewaa/event-broker", | ||
"version": "7.1.0", | ||
"version": "7.1.2", | ||
"description": "A broker for all the events that Rewaa will ever produce or consume", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
266859
0