rabbitmq-queue-stream - npm Package Compare versions

Comparing version 0.4.2 to 0.4.3

index.js

@@ -504,10 +504,11 @@ var _                 = require("lodash");
     var nextItem = testMessages.shift();
-    if(nextItem) {
-      itemWrapper = {
-        headers: {},
-        deliveryInfo: {},
-        payload: nextItem,
-        _meta: {}
-      };
+    if(!nextItem) {
+      return this.push(null);
     }
+    itemWrapper = {
+      headers: {},
+      deliveryInfo: {},
+      payload: nextItem,
+      _meta: {}
+    };
     this.push(itemWrapper);
@@ -514,0 +515,0 @@ };

package.json

 {
   "name": "rabbitmq-queue-stream",
-  "version": "0.4.2",
+  "version": "0.4.3",
   "description": "Reliable streaming interface to rabbitmq queues",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

@@ -971,3 +971,2 @@ var EventEmitter    = require("events").EventEmitter;
       collectedMessages.push(item);
-      this.push();
       next();
@@ -974,0 +973,0 @@ };

No alert changes

No metric changes

No dependency changes