fix build issues and add typedoc

1 files changed, 11 insertions, 11 deletions

diff --git a/node_modules/async/internal/queue.js b/node_modules/async/internal/queue.js
index ff3d6d13a..8188368b9 100644
--- a/node_modules/async/internal/queue.js
+++ b/node_modules/async/internal/queue.js
@@ -17,10 +17,6 @@ var _noop = require('lodash/noop');
 
 var _noop2 = _interopRequireDefault(_noop);
 
-var _rest = require('./rest');
-
-var _rest2 = _interopRequireDefault(_rest);
-
 var _onlyOnce = require('./onlyOnce');
 
 var _onlyOnce2 = _interopRequireDefault(_onlyOnce);
@@ -81,7 +77,7 @@ function queue(worker, concurrency, payload) {
     }
 
     function _next(tasks) {
-        return (0, _rest2.default)(function (args) {
+        return function (err) {
             numRunning -= 1;
 
             for (var i = 0, l = tasks.length; i < l; i++) {
@@ -91,10 +87,10 @@ function queue(worker, concurrency, payload) {
                     workersList.splice(index);
                 }
 
-                task.callback.apply(task, args);
+                task.callback.apply(task, arguments);
 
-                if (args[0] != null) {
-                    q.error(args[0], task.data);
+                if (err != null) {
+                    q.error(err, task.data);
                 }
             }
 
@@ -106,7 +102,7 @@ function queue(worker, concurrency, payload) {
                 q.drain();
             }
             q.process();
-        });
+        };
     }
 
     var isProcessing = false;
@@ -132,6 +128,9 @@ function queue(worker, concurrency, payload) {
         unshift: function (data, callback) {
             _insert(data, true, callback);
         },
+        remove: function (testFn) {
+            q._tasks.remove(testFn);
+        },
         process: function () {
             // Avoid trying to start too many processing operations. This can occur
             // when callbacks resolve synchronously (#1267).
@@ -150,11 +149,12 @@ function queue(worker, concurrency, payload) {
                     data.push(node.data);
                 }
 
+                numRunning += 1;
+                workersList.push(tasks[0]);
+
                 if (q._tasks.length === 0) {
                     q.empty();
                 }
-                numRunning += 1;
-                workersList.push(tasks[0]);
 
                 if (numRunning === q.concurrency) {
                     q.saturated();