aboutsummaryrefslogtreecommitdiff
path: root/node_modules/async/priorityQueue.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
committerFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
commitd1291f67551c58168af43698a359cb5ddfd266b0 (patch)
tree55a13ed29fe1915e3f42f1b1b7038dafa2e975a7 /node_modules/async/priorityQueue.js
parentd0a0695fb5d34996850723f7d4b1b59c3df909c2 (diff)
node_modules
Diffstat (limited to 'node_modules/async/priorityQueue.js')
-rw-r--r--node_modules/async/priorityQueue.js10
1 files changed, 3 insertions, 7 deletions
diff --git a/node_modules/async/priorityQueue.js b/node_modules/async/priorityQueue.js
index f7736e9f9..4e3714995 100644
--- a/node_modules/async/priorityQueue.js
+++ b/node_modules/async/priorityQueue.js
@@ -31,9 +31,9 @@ exports.default = function (worker, concurrency) {
nextNode = nextNode.next;
}
- (0, _arrayEach2.default)(data, function (task) {
+ for (var i = 0, l = data.length; i < l; i++) {
var item = {
- data: task,
+ data: data[i],
priority: priority,
callback: callback
};
@@ -43,7 +43,7 @@ exports.default = function (worker, concurrency) {
} else {
q._tasks.push(item);
}
- });
+ }
(0, _setImmediate2.default)(q.process);
};
@@ -53,10 +53,6 @@ exports.default = function (worker, concurrency) {
return q;
};
-var _arrayEach = require('lodash/_arrayEach');
-
-var _arrayEach2 = _interopRequireDefault(_arrayEach);
-
var _isArray = require('lodash/isArray');
var _isArray2 = _interopRequireDefault(_isArray);