Launch Week Day 5: Introducing Reachability for PHP.Learn More
Socket
Book a DemoSign in
Socket

mqemitter

Package Overview
Dependencies
Maintainers
1
Versions
34
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

mqemitter - npm Package Compare versions

Comparing version
0.4.0
to
0.5.0
+5
-1
.travis.yml

@@ -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) {

@@ -16,3 +16,3 @@ /*

*/
'use strict';
'use strict'

@@ -19,0 +19,0 @@ var mqemitter = require('./')

@@ -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

{
"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"
}
}

@@ -16,3 +16,3 @@ /*

*/
'use strict';
'use strict'

@@ -19,0 +19,0 @@ var abstractTest = require('./abstractTest')