node_modules

1 files changed, 16 insertions, 16 deletions

diff --git a/node_modules/async/internal/queue.js b/node_modules/async/internal/queue.js
index e54a6d7c9..6d53cc2e0 100644
--- a/node_modules/async/internal/queue.js
+++ b/node_modules/async/internal/queue.js
@@ -5,9 +5,9 @@ Object.defineProperty(exports, "__esModule", {
 });
 exports.default = queue;
 
-var _arrayEach = require('lodash/_arrayEach');
+var _baseIndexOf = require('lodash/_baseIndexOf');
 
-var _arrayEach2 = _interopRequireDefault(_arrayEach);
+var _baseIndexOf2 = _interopRequireDefault(_baseIndexOf);
 
 var _isArray = require('lodash/isArray');
 
@@ -17,9 +17,9 @@ var _noop = require('lodash/noop');
 
 var _noop2 = _interopRequireDefault(_noop);
 
-var _rest = require('lodash/rest');
+var _baseRest = require('lodash/_baseRest');
 
-var _rest2 = _interopRequireDefault(_rest);
+var _baseRest2 = _interopRequireDefault(_baseRest);
 
 var _onlyOnce = require('./onlyOnce');
 
@@ -56,9 +56,10 @@ function queue(worker, concurrency, payload) {
                 q.drain();
             });
         }
-        (0, _arrayEach2.default)(data, function (task) {
+
+        for (var i = 0, l = data.length; i < l; i++) {
             var item = {
-                data: task,
+                data: data[i],
                 callback: callback || _noop2.default
             };
 
@@ -67,28 +68,27 @@ function queue(worker, concurrency, payload) {
             } else {
                 q._tasks.push(item);
             }
-        });
+        }
         (0, _setImmediate2.default)(q.process);
     }
 
     function _next(tasks) {
-        return (0, _rest2.default)(function (args) {
+        return (0, _baseRest2.default)(function (args) {
             workers -= 1;
 
-            (0, _arrayEach2.default)(tasks, function (task) {
-                (0, _arrayEach2.default)(workersList, function (worker, index) {
-                    if (worker === task) {
-                        workersList.splice(index, 1);
-                        return false;
-                    }
-                });
+            for (var i = 0, l = tasks.length; i < l; i++) {
+                var task = tasks[i];
+                var index = (0, _baseIndexOf2.default)(workersList, task, 0);
+                if (index >= 0) {
+                    workersList.splice(index);
+                }
 
                 task.callback.apply(task, args);
 
                 if (args[0] != null) {
                     q.error(args[0], task.data);
                 }
-            });
+            }
 
             if (workers <= q.concurrency - q.buffer) {
                 q.unsaturated();