diff options
-rw-r--r-- | lib/internal/queue.js | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index dcf376e..e3887cb 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -1,5 +1,4 @@ import arrayEach from 'lodash/_arrayEach'; -import arraySome from 'lodash/_arraySome'; import isArray from 'lodash/isArray'; import noop from 'lodash/noop'; import rest from 'lodash/rest'; @@ -51,10 +50,10 @@ export default function queue(worker, concurrency, payload) { workers -= 1; arrayEach(tasks, function (task) { - arraySome(workersList, function (worker, index) { + arrayEach(workersList, function (worker, index) { if (worker === task) { workersList.splice(index, 1); - return true; + return false; } }); |