fastq
Advanced tools
Comparing version 1.17.0 to 1.17.1
{ | ||
"name": "fastq", | ||
"version": "1.17.0", | ||
"version": "1.17.1", | ||
"description": "Fast, in memory work queue", | ||
@@ -5,0 +5,0 @@ "main": "queue.js", |
@@ -96,2 +96,7 @@ 'use strict' | ||
self.paused = false | ||
if (queueHead === null) { | ||
_running++ | ||
release() | ||
return | ||
} | ||
for (; queueHead && _running < _concurrency;) { | ||
@@ -98,0 +103,0 @@ _running++ |
@@ -5,3 +5,2 @@ # fastq | ||
[![npm version][npm-badge]][npm-url] | ||
[![Dependency Status][david-badge]][david-url] | ||
@@ -309,3 +308,1 @@ Fast, in memory work queue. | ||
[npm-url]: https://badge.fury.io/js/fastq | ||
[david-badge]: https://david-dm.org/mcollina/fastq.svg | ||
[david-url]: https://david-dm.org/mcollina/fastq |
@@ -627,1 +627,17 @@ 'use strict' | ||
}) | ||
test('pause/resume should trigger drain event', function (t) { | ||
t.plan(1) | ||
var queue = buildQueue(worker, 1) | ||
queue.pause() | ||
queue.drain = function () { | ||
t.pass('drain should be called') | ||
} | ||
function worker (arg, cb) { | ||
cb(null, true) | ||
} | ||
queue.resume() | ||
}) |
41927
1117
307