diff --git a/mqemitter.js b/mqemitter.js index b97a498..4521a30 100644 --- a/mqemitter.js +++ b/mqemitter.js @@ -21,7 +21,7 @@ function MQEmitter (opts) { this._messageCallbacks = [] this._parallel = fastparallel({ results: false, - released: released + released }) this.concurrency = opts.concurrency || 0 diff --git a/test/test.js b/test/test.js index 486caa2..f620d85 100644 --- a/test/test.js +++ b/test/test.js @@ -5,7 +5,7 @@ const mq = require('../') require('../abstractTest')({ builder: mq, - test: test + test }) test('queue concurrency', function (t) {