summaryrefslogtreecommitdiff
path: root/lib/internal/queue.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/queue.js')
-rw-r--r--lib/internal/queue.js5
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;
}
});