@nerimity/mimiqueue - npm Package Compare versions

Comparing version 2.0.2 to 2.0.3

package.json

 {
   "name": "@nerimity/mimiqueue",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "description": "NodeJS group queuing library. Requires Redis.",
@@ -5,0 +5,0 @@ "main": "dist/index.mjs",

src/createQueue.ts

@@ -29,15 +29,17 @@ import {
 export const createQueue = (opts: createQueueOpts) => {
-  opts.redisClient.publish(
-    "mq",
-    JSON.stringify({
-      event: "options",
-      name: opts.name,
-      minTime: opts.minTime,
-    } as OptionsEvent)
-  );
-
   const localWaitList = new Map<string, WaitList>();
 
+  const pub = opts.redisClient.duplicate();
   const sub = opts.redisClient.duplicate();
   sub.connect();
+  pub.connect().then(() => {
+    opts.redisClient.publish(
+      "mq",
+      JSON.stringify({
+        event: "options",
+        name: opts.name,
+        minTime: opts.minTime,
+      } as OptionsEvent)
+    );
+  });
 
@@ -44,0 +46,0 @@ sub.subscribe("mq", async (message) => {

No alert changes

Improved metrics

Total package byte prevSize

20610

increased by1.57%

Lines of code

282

increased by1.08%

No dependency changes