node_modules

1 files changed, 3 insertions, 2 deletions

diff --git a/node_modules/async/internal/queue.js b/node_modules/async/internal/queue.js
index 8188368b9..6a7c455a8 100644
--- a/node_modules/async/internal/queue.js
+++ b/node_modules/async/internal/queue.js
@@ -82,9 +82,10 @@ function queue(worker, concurrency, payload) {
 
             for (var i = 0, l = tasks.length; i < l; i++) {
                 var task = tasks[i];
+
                 var index = (0, _baseIndexOf2.default)(workersList, task, 0);
                 if (index >= 0) {
-                    workersList.splice(index);
+                    workersList.splice(index, 1);
                 }
 
                 task.callback.apply(task, arguments);
@@ -146,11 +147,11 @@ function queue(worker, concurrency, payload) {
                 for (var i = 0; i < l; i++) {
                     var node = q._tasks.shift();
                     tasks.push(node);
+                    workersList.push(node);
                     data.push(node.data);
                 }
 
                 numRunning += 1;
-                workersList.push(tasks[0]);
 
                 if (q._tasks.length === 0) {
                     q.empty();