+5
-1
@@ -5,2 +5,6 @@ language: node_js | ||
| - "0.12" | ||
| - iojs | ||
| - iojs-v1 | ||
| - iojs-v2 | ||
| - iojs-v3 | ||
| - "4.0" | ||
| - "4.1" |
+1
-1
@@ -16,3 +16,3 @@ /* | ||
| */ | ||
| 'use strict'; | ||
| 'use strict' | ||
@@ -19,0 +19,0 @@ function buildTests (opts) { |
+1
-1
@@ -16,3 +16,3 @@ /* | ||
| */ | ||
| 'use strict'; | ||
| 'use strict' | ||
@@ -19,0 +19,0 @@ var mqemitter = require('./') |
+5
-11
@@ -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 |
+5
-5
| { | ||
| "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" | ||
| } | ||
| } |
+1
-1
@@ -16,3 +16,3 @@ /* | ||
| */ | ||
| 'use strict'; | ||
| 'use strict' | ||
@@ -19,0 +19,0 @@ var abstractTest = require('./abstractTest') |
21913
-0.44%513
-1.35%+ Added
- Removed
Updated