aggiunto di nuovo bower e node, speriamo stavolta vada...
This commit is contained in:
+16
-16
@@ -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();
|
||||
|
||||
Reference in New Issue
Block a user