aboutsummaryrefslogtreecommitdiff
path: root/node_modules/async/priorityQueue.js
diff options
context:
space:
mode:
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);