diff options
Diffstat (limited to 'node_modules/async/internal')
| -rw-r--r-- | node_modules/async/internal/DoublyLinkedList.js | 27 | ||||
| -rw-r--r-- | node_modules/async/internal/applyEach.js | 9 | ||||
| -rw-r--r-- | node_modules/async/internal/consoleFunc.js | 15 | ||||
| -rw-r--r-- | node_modules/async/internal/initialParams.js | 9 | ||||
| -rw-r--r-- | node_modules/async/internal/parallel.js | 14 | ||||
| -rw-r--r-- | node_modules/async/internal/queue.js | 22 | ||||
| -rw-r--r-- | node_modules/async/internal/rest.js | 23 | ||||
| -rw-r--r-- | node_modules/async/internal/setImmediate.js | 9 | ||||
| -rw-r--r-- | node_modules/async/internal/slice.js | 16 | ||||
| -rw-r--r-- | node_modules/async/internal/wrapAsync.js | 20 |
10 files changed, 86 insertions, 78 deletions
diff --git a/node_modules/async/internal/DoublyLinkedList.js b/node_modules/async/internal/DoublyLinkedList.js index 796d1230b..7e71728e2 100644 --- a/node_modules/async/internal/DoublyLinkedList.js +++ b/node_modules/async/internal/DoublyLinkedList.js @@ -27,7 +27,10 @@ DLL.prototype.removeLink = function (node) { return node; }; -DLL.prototype.empty = DLL; +DLL.prototype.empty = function () { + while (this.head) this.shift(); + return this; +}; DLL.prototype.insertAfter = function (node, newNode) { newNode.prev = node; @@ -60,4 +63,26 @@ DLL.prototype.shift = function () { DLL.prototype.pop = function () { return this.tail && this.removeLink(this.tail); }; + +DLL.prototype.toArray = function () { + var arr = Array(this.length); + var curr = this.head; + for (var idx = 0; idx < this.length; idx++) { + arr[idx] = curr.data; + curr = curr.next; + } + return arr; +}; + +DLL.prototype.remove = function (testFn) { + var curr = this.head; + while (!!curr) { + var next = curr.next; + if (testFn(curr)) { + this.removeLink(curr); + } + curr = next; + } + return this; +}; module.exports = exports["default"];
\ No newline at end of file diff --git a/node_modules/async/internal/applyEach.js b/node_modules/async/internal/applyEach.js index 92f1d2872..322e03ca7 100644 --- a/node_modules/async/internal/applyEach.js +++ b/node_modules/async/internal/applyEach.js @@ -5,9 +5,9 @@ Object.defineProperty(exports, "__esModule", { }); exports.default = applyEach; -var _rest = require('./rest'); +var _slice = require('./slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); var _initialParams = require('./initialParams'); @@ -20,7 +20,8 @@ var _wrapAsync2 = _interopRequireDefault(_wrapAsync); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } function applyEach(eachfn) { - return (0, _rest2.default)(function (fns, args) { + return function (fns /*, ...args*/) { + var args = (0, _slice2.default)(arguments, 1); var go = (0, _initialParams2.default)(function (args, callback) { var that = this; return eachfn(fns, function (fn, cb) { @@ -32,6 +33,6 @@ function applyEach(eachfn) { } else { return go; } - }); + }; } module.exports = exports['default'];
\ No newline at end of file diff --git a/node_modules/async/internal/consoleFunc.js b/node_modules/async/internal/consoleFunc.js index 56c1de01c..603f48e8e 100644 --- a/node_modules/async/internal/consoleFunc.js +++ b/node_modules/async/internal/consoleFunc.js @@ -9,9 +9,9 @@ var _arrayEach = require('lodash/_arrayEach'); var _arrayEach2 = _interopRequireDefault(_arrayEach); -var _rest = require('./rest'); +var _slice = require('./slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); var _wrapAsync = require('./wrapAsync'); @@ -20,8 +20,10 @@ var _wrapAsync2 = _interopRequireDefault(_wrapAsync); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } function consoleFunc(name) { - return (0, _rest2.default)(function (fn, args) { - (0, _wrapAsync2.default)(fn).apply(null, args.concat((0, _rest2.default)(function (err, args) { + return function (fn /*, ...args*/) { + var args = (0, _slice2.default)(arguments, 1); + args.push(function (err /*, ...args*/) { + var args = (0, _slice2.default)(arguments, 1); if (typeof console === 'object') { if (err) { if (console.error) { @@ -33,7 +35,8 @@ function consoleFunc(name) { }); } } - }))); - }); + }); + (0, _wrapAsync2.default)(fn).apply(null, args); + }; } module.exports = exports['default'];
\ No newline at end of file diff --git a/node_modules/async/internal/initialParams.js b/node_modules/async/internal/initialParams.js index 48f059ba4..df02cb1f1 100644 --- a/node_modules/async/internal/initialParams.js +++ b/node_modules/async/internal/initialParams.js @@ -5,15 +5,16 @@ Object.defineProperty(exports, "__esModule", { }); exports.default = function (fn) { - return (0, _rest2.default)(function (args /*..., callback*/) { + return function () /*...args, callback*/{ + var args = (0, _slice2.default)(arguments); var callback = args.pop(); fn.call(this, args, callback); - }); + }; }; -var _rest = require('./rest'); +var _slice = require('./slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } diff --git a/node_modules/async/internal/parallel.js b/node_modules/async/internal/parallel.js index 1a27c2a54..c97293b6c 100644 --- a/node_modules/async/internal/parallel.js +++ b/node_modules/async/internal/parallel.js @@ -13,9 +13,9 @@ var _isArrayLike = require('lodash/isArrayLike'); var _isArrayLike2 = _interopRequireDefault(_isArrayLike); -var _rest = require('./rest'); +var _slice = require('./slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); var _wrapAsync = require('./wrapAsync'); @@ -28,13 +28,13 @@ function _parallel(eachfn, tasks, callback) { var results = (0, _isArrayLike2.default)(tasks) ? [] : {}; eachfn(tasks, function (task, key, callback) { - (0, _wrapAsync2.default)(task)((0, _rest2.default)(function (err, args) { - if (args.length <= 1) { - args = args[0]; + (0, _wrapAsync2.default)(task)(function (err, result) { + if (arguments.length > 2) { + result = (0, _slice2.default)(arguments, 1); } - results[key] = args; + results[key] = result; callback(err); - })); + }); }, function (err) { callback(err, results); }); 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(); diff --git a/node_modules/async/internal/rest.js b/node_modules/async/internal/rest.js deleted file mode 100644 index 9b2b57907..000000000 --- a/node_modules/async/internal/rest.js +++ /dev/null @@ -1,23 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = rest; - -var _overRest2 = require('lodash/_overRest'); - -var _overRest3 = _interopRequireDefault(_overRest2); - -var _identity = require('lodash/identity'); - -var _identity2 = _interopRequireDefault(_identity); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -// Lodash rest function without function.toString() -// remappings -function rest(func, start) { - return (0, _overRest3.default)(func, start, _identity2.default); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/node_modules/async/internal/setImmediate.js b/node_modules/async/internal/setImmediate.js index 27e7f2e66..3545f2bcd 100644 --- a/node_modules/async/internal/setImmediate.js +++ b/node_modules/async/internal/setImmediate.js @@ -7,9 +7,9 @@ exports.hasNextTick = exports.hasSetImmediate = undefined; exports.fallback = fallback; exports.wrap = wrap; -var _rest = require('./rest'); +var _slice = require('./slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } @@ -21,11 +21,12 @@ function fallback(fn) { } function wrap(defer) { - return (0, _rest2.default)(function (fn, args) { + return function (fn /*, ...args*/) { + var args = (0, _slice2.default)(arguments, 1); defer(function () { fn.apply(null, args); }); - }); + }; } var _defer; diff --git a/node_modules/async/internal/slice.js b/node_modules/async/internal/slice.js new file mode 100644 index 000000000..56f10c03e --- /dev/null +++ b/node_modules/async/internal/slice.js @@ -0,0 +1,16 @@ +"use strict"; + +Object.defineProperty(exports, "__esModule", { + value: true +}); +exports.default = slice; +function slice(arrayLike, start) { + start = start | 0; + var newLen = Math.max(arrayLike.length - start, 0); + var newArr = Array(newLen); + for (var idx = 0; idx < newLen; idx++) { + newArr[idx] = arrayLike[start + idx]; + } + return newArr; +} +module.exports = exports["default"];
\ No newline at end of file diff --git a/node_modules/async/internal/wrapAsync.js b/node_modules/async/internal/wrapAsync.js index 862dc90f2..bc6c96668 100644 --- a/node_modules/async/internal/wrapAsync.js +++ b/node_modules/async/internal/wrapAsync.js @@ -3,11 +3,7 @@ Object.defineProperty(exports, "__esModule", { value: true }); -exports.isAsync = exports.supportsAsync = undefined; - -var _identity = require('lodash/identity'); - -var _identity2 = _interopRequireDefault(_identity); +exports.isAsync = undefined; var _asyncify = require('../asyncify'); @@ -17,17 +13,6 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de var supportsSymbol = typeof Symbol === 'function'; -function supportsAsync() { - var supported; - try { - /* eslint no-eval: 0 */ - supported = isAsync(eval('(async function () {})')); - } catch (e) { - supported = false; - } - return supported; -} - function isAsync(fn) { return supportsSymbol && fn[Symbol.toStringTag] === 'AsyncFunction'; } @@ -36,6 +21,5 @@ function wrapAsync(asyncFn) { return isAsync(asyncFn) ? (0, _asyncify2.default)(asyncFn) : asyncFn; } -exports.default = supportsAsync() ? wrapAsync : _identity2.default; -exports.supportsAsync = supportsAsync; +exports.default = wrapAsync; exports.isAsync = isAsync;
\ No newline at end of file |