Avoid unnessary queuing of *concurrency processes on resumepr/1267

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;