From 4e6375fd55ddd820357655468f3c201cccad866e Mon Sep 17 00:00:00 2001
From: Hubert Argasinski <argasinski.hubert@gmail.com>
Date: Sun, 9 Jul 2017 17:06:45 -0400
Subject: prevent overwriting q.process from pausing the queue

---
 lib/internal/queue.js | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index b06f12e..4f57edb 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -18,8 +18,8 @@ export default function queue(worker, concurrency, payload) {
     var _worker = wrapAsync(worker);
     var numRunning = 0;
     var workersList = [];
-    var isWaitingForProcessing = false;
 
+    var processingScheduled = false;
     function _insert(data, insertAtFront, callback) {
         if (callback != null && typeof callback !== 'function') {
             throw new Error('task callback must be a function');
@@ -48,9 +48,12 @@ export default function queue(worker, concurrency, payload) {
             }
         }
 
-        if (!isWaitingForProcessing) {
-            isWaitingForProcessing = true;
-            setImmediate(q.process);
+        if (!processingScheduled) {
+            processingScheduled = true;
+            setImmediate(function() {
+                processingScheduled = false;
+                q.process();
+            });
         }
     }
 
@@ -111,8 +114,6 @@ export default function queue(worker, concurrency, payload) {
             q._tasks.remove(testFn);
         },
         process: function () {
-            isWaitingForProcessing = false;
-
             // Avoid trying to start too many processing operations. This can occur
             // when callbacks resolve synchronously (#1267).
             if (isProcessing) {
-- 
cgit v1.2.1