diff options
Diffstat (limited to 'node_modules/async/internal/queue.js')
| -rw-r--r-- | node_modules/async/internal/queue.js | 5 |
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(); |