rabbit-queue - npm Package Compare versions

Comparing version 4.7.0 to 4.7.1

js/rabbit.d.ts

@@ -15,3 +15,3 @@ /// <reference types="node" />
     connected: Promise<any>;
-    changingPrefetch: Promise<void>;
+    lock: Promise<void>;
     queues: {
@@ -18,0 +18,0 @@ [s: string]: Queue;

js/rabbit.js

@@ -99,14 +99,15 @@ "use strict";
             if (handler) {
-                let localPrefetch;
+                let localLock;
                 do {
-                    localPrefetch = this.changingPrefetch;
-                    yield this.changingPrefetch;
-                } while (this.changingPrefetch !== localPrefetch);
+                    localLock = this.lock;
+                    yield this.lock;
+                } while (this.lock !== localLock);
                 if (this.prefetch !== options.prefetch) {
                     this.prefetch = options.prefetch;
-                    this.changingPrefetch = Promise.resolve(this.channel.prefetch(options.prefetch)).then(() => queue.subscribe(handler));
-                    yield this.changingPrefetch;
+                    this.lock = Promise.resolve(this.channel.prefetch(options.prefetch)).then(() => queue.subscribe(handler));
+                    yield this.lock;
                 }
                 else {
-                    yield queue.subscribe(handler);
+                    this.lock = queue.subscribe(handler);
+                    yield this.lock;
                 }
@@ -113,0 +114,0 @@ }

package.json

 {
   "name": "rabbit-queue",
-  "version": "4.7.0",
+  "version": "4.7.1",
   "description": "AMQP/RabbitMQ queue management library.",
@@ -5,0 +5,0 @@ "main": "js/index.js",

No alert changes

Improved metrics

Lines of code

1392

increased by0.07%

Worsened metrics

Total package byte prevSize

115049

No dependency changes