summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Early <alexander.early@gmail.com>2016-07-07 17:16:07 -0700
committerAlexander Early <alexander.early@gmail.com>2016-07-07 17:16:07 -0700
commitf21e7dbeefe37d32d592cb80992def758c023629 (patch)
tree6b1c4780d6755c50d74e9a574058ad9a0351776c
parentef05d55e1bbe1a8c823eaa4d5e0de6f5818ff27e (diff)
downloadasync-queue-opts.tar.gz
use each instead of somequeue-opts
-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;
}
});