diff options
author | Florian Dold <florian.dold@gmail.com> | 2016-11-03 01:33:53 +0100 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2016-11-03 01:33:53 +0100 |
commit | d1291f67551c58168af43698a359cb5ddfd266b0 (patch) | |
tree | 55a13ed29fe1915e3f42f1b1b7038dafa2e975a7 /node_modules/async/priorityQueue.js | |
parent | d0a0695fb5d34996850723f7d4b1b59c3df909c2 (diff) |
node_modules
Diffstat (limited to 'node_modules/async/priorityQueue.js')
-rw-r--r-- | node_modules/async/priorityQueue.js | 10 |
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); |