diff options
author | Graeme Yeates <yeatesgraeme@gmail.com> | 2016-07-23 11:13:22 -0400 |
---|---|---|
committer | Graeme Yeates <yeatesgraeme@gmail.com> | 2016-07-23 11:13:22 -0400 |
commit | 66d6bbe7f174bc3adebf71d23d43d6bf05a64fb3 (patch) | |
tree | 8e50c6279bfdcb672efebba31d173994bdf925a6 /lib/priorityQueue.js | |
parent | 4cdeecf56e42ec5150e453e5cf93c89439b15463 (diff) | |
download | async-66d6bbe7f174bc3adebf71d23d43d6bf05a64fb3.tar.gz |
Unroll simple loop abstractions
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); }; |