Comparing version 6.0.1 to 6.0.2
@@ -6,3 +6,2 @@ 'use strict' | ||
const test = opts.test | ||
const packetsInOrder = opts.packetsInOrder === undefined ? true : opts.packetsInOrder | ||
@@ -508,3 +507,3 @@ test('support on and emit', function (t) { | ||
let fail = false | ||
if (packetsInOrder && received !== msg.payload) { | ||
if (received !== msg.payload) { | ||
t.fail(`leak detected. Count: ${received} - Payload: ${msg.payload}`) | ||
@@ -522,7 +521,7 @@ fail = true | ||
cb() | ||
}, function () { | ||
for (let payload = 0; payload < total; payload++) { | ||
e.emit({ topic, payload }) | ||
} | ||
}) | ||
for (let payload = 0; payload < total; payload++) { | ||
e.emit({ topic, payload }) | ||
} | ||
}) | ||
@@ -529,0 +528,0 @@ |
{ | ||
"name": "mqemitter", | ||
"version": "6.0.1", | ||
"version": "6.0.2", | ||
"description": "An Opinionated Message Queue with an emitter-style API", | ||
@@ -5,0 +5,0 @@ "main": "mqemitter.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
37591