diff options
Diffstat (limited to 'lib/priorityQueue.js')
-rw-r--r-- | lib/priorityQueue.js | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/lib/priorityQueue.js b/lib/priorityQueue.js index d8b6016..0af0157 100644 --- a/lib/priorityQueue.js +++ b/lib/priorityQueue.js @@ -1,4 +1,3 @@ -import arrayEach from 'lodash/_arrayEach'; import isArray from 'lodash/isArray'; import noop from 'lodash/noop'; @@ -57,9 +56,9 @@ export default function(worker, concurrency) { nextNode = nextNode.next; } - arrayEach(data, function(task) { + for (var i = 0, l = data.length; i < l; i++) { var item = { - data: task, + data: data[i], priority: priority, callback: callback }; @@ -69,7 +68,7 @@ export default function(worker, concurrency) { } else { q._tasks.push(item); } - }); + } setImmediate(q.process); }; |