mqemitter - npm Package Compare versions

Comparing version 0.4.0 to 0.5.0

abstractTest.js

@@ -16,3 +16,3 @@ /*
 */
-'use strict';
+'use strict'
 
@@ -19,0 +19,0 @@ function buildTests (opts) {

bench.js

@@ -16,3 +16,3 @@ /*
 */
-'use strict';
+'use strict'
 
@@ -19,0 +19,0 @@ var mqemitter = require('./')

mqemitter.js

@@ -55,9 +55,8 @@ /*
   function released () {
+    that.current--
+
     var message = that._messageQueue.shift()
     var callback = that._messageCallbacks.shift()
 
-    if (!message) {
-      // we are at the end of the queue
-      that.current--
-    } else {
+    if (message) {
       that._do(message, callback)
@@ -112,3 +111,2 @@ }
   } else {
-    this.current++
     this._do(message, cb)
@@ -130,8 +128,4 @@ }
 
-  if (matches.length === 0) {
-    callback()
-    this._released()
-  } else {
-    this._parallel(this, matches, message, callback)
-  }
+  this.current++
+  this._parallel(this, matches, message, callback)
 
@@ -138,0 +132,0 @@ return this

package.json

 {
   "name": "mqemitter",
-  "version": "0.4.0",
+  "version": "0.5.0",
   "description": "An Opinionated Message Queue with an emitter-style API",
@@ -36,10 +36,10 @@ "main": "mqemitter.js",
     "faucet": "0.0.1",
-    "pre-commit": "0.0.9",
-    "standard": "^3.1.0",
-    "tape": "^2.14.0"
+    "pre-commit": "^1.0.7",
+    "standard": "^5.0.0",
+    "tape": "^4.0.0"
   },
   "dependencies": {
-    "fastparallel": "^1.1.1",
+    "fastparallel": "^2.0.0",
     "qlobber": "~0.5.0"
   }
 }

test.js

@@ -16,3 +16,3 @@ /*
 */
-'use strict';
+'use strict'
 
@@ -19,0 +19,0 @@ var abstractTest = require('./abstractTest')

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

21913

decreased by-0.44%

Lines of code

513

decreased by-1.35%

Dependency changes

• + Addedfastparallel@2.4.1(transitive)

• - Removedfastparallel@1.7.2(transitive)

• Updatedfastparallel@^2.0.0