summaryrefslogtreecommitdiff
path: root/lib/priorityQueue.js
diff options
context:
space:
mode:
authorGraeme Yeates <yeatesgraeme@gmail.com>2016-07-23 11:13:22 -0400
committerGraeme Yeates <yeatesgraeme@gmail.com>2016-07-23 11:13:22 -0400
commit66d6bbe7f174bc3adebf71d23d43d6bf05a64fb3 (patch)
tree8e50c6279bfdcb672efebba31d173994bdf925a6 /lib/priorityQueue.js
parent4cdeecf56e42ec5150e453e5cf93c89439b15463 (diff)
downloadasync-66d6bbe7f174bc3adebf71d23d43d6bf05a64fb3.tar.gz
Unroll simple loop abstractions
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);
};