diff options
| -rw-r--r-- | lib/internal/queue.js | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 15fb950..7a438da 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -149,12 +149,7 @@ export default function queue(worker, concurrency, payload) { resume: function () { if (q.paused === false) { return; } q.paused = false; - var resumeCount = Math.min(q.concurrency, q._tasks.length); - // Need to call q.process once per concurrent - // worker to preserve full concurrency after pause - for (var w = 1; w <= resumeCount; w++) { - setImmediate(q.process); - } + setImmediate(q.process); } }; return q; |