3 files changed, 3 insertions, 43 deletions
diff --git a/node_modules/async/internal/concat.js b/node_modules/async/internal/concat.js
deleted file mode 100644
index f2ffb5379..000000000
--- a/node_modules/async/internal/concat.js
+++ /dev/null
@@ -1,18 +0,0 @@
-"use strict";
-
-Object.defineProperty(exports, "__esModule", {
-    value: true
-});
-exports.default = concat;
-function concat(eachfn, arr, fn, callback) {
-    var result = [];
-    eachfn(arr, function (x, index, cb) {
-        fn(x, function (err, y) {
-            result = result.concat(y || []);
-            cb(err);
-        });
-    }, function (err) {
-        callback(err, result);
-    });
-}
-module.exports = exports["default"];
-\ No newline at end of file
diff --git a/node_modules/async/internal/doSeries.js b/node_modules/async/internal/doSeries.js
deleted file mode 100644
index f3ca5aa83..000000000
--- a/node_modules/async/internal/doSeries.js
+++ /dev/null
@@ -1,23 +0,0 @@
-'use strict';
-
-Object.defineProperty(exports, "__esModule", {
-    value: true
-});
-exports.default = doSeries;
-
-var _eachOfSeries = require('../eachOfSeries');
-
-var _eachOfSeries2 = _interopRequireDefault(_eachOfSeries);
-
-var _wrapAsync = require('./wrapAsync');
-
-var _wrapAsync2 = _interopRequireDefault(_wrapAsync);
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
-function doSeries(fn) {
-    return function (obj, iteratee, callback) {
-        return fn(_eachOfSeries2.default, obj, (0, _wrapAsync2.default)(iteratee), callback);
-    };
-}
-module.exports = exports['default'];
-\ No newline at end of file
diff --git a/node_modules/async/internal/queue.js b/node_modules/async/internal/queue.js
index 8188368b9..6a7c455a8 100644
--- a/node_modules/async/internal/queue.js
+++ b/node_modules/async/internal/queue.js
@@ -82,9 +82,10 @@ function queue(worker, concurrency, payload) {
 
             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);
+                    workersList.splice(index, 1);
                 }
 
                 task.callback.apply(task, arguments);
@@ -146,11 +147,11 @@ function queue(worker, concurrency, payload) {
                 for (var i = 0; i < l; i++) {
                     var node = q._tasks.shift();
                     tasks.push(node);
+                    workersList.push(node);
                     data.push(node.data);
                 }
 
                 numRunning += 1;
-                workersList.push(tasks[0]);
 
                 if (q._tasks.length === 0) {
                     q.empty();