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