From 363723fc84f7b8477592e0105aeb331ec9a017af Mon Sep 17 00:00:00 2001 From: Florian Dold Date: Mon, 14 Aug 2017 05:01:11 +0200 Subject: node_modules --- node_modules/async/internal/concat.js | 18 ------------------ node_modules/async/internal/doSeries.js | 23 ----------------------- node_modules/async/internal/queue.js | 5 +++-- 3 files changed, 3 insertions(+), 43 deletions(-) delete mode 100644 node_modules/async/internal/concat.js delete mode 100644 node_modules/async/internal/doSeries.js (limited to 'node_modules/async/internal') 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(); -- cgit v1.2.3