summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Early <alexander.early@gmail.com>2015-07-02 00:36:26 -0700
committerAlexander Early <alexander.early@gmail.com>2015-07-02 00:36:26 -0700
commitea84790dac32cfebec2dfcf57533258a42d0d335 (patch)
tree2359a28f366ba0ff1fdde746dffc90c73ff966f0
parentac170ba5a22a7b8ffaf03ad638e8857fe7150d86 (diff)
parent5fdc96a66f59b9deca1780ec3f53c4a0111c262a (diff)
downloadasync-ea84790dac32cfebec2dfcf57533258a42d0d335.tar.gz
Merge pull request #821 from megawac/series-parallel
Implement series via _parallel
-rw-r--r--lib/async.js17
1 files changed, 2 insertions, 15 deletions
diff --git a/lib/async.js b/lib/async.js
index 312000f..f176085 100644
--- a/lib/async.js
+++ b/lib/async.js
@@ -720,21 +720,8 @@
_parallel(_eachOfLimit(limit), tasks, callback);
};
- async.series = function (tasks, callback) {
- callback = callback || noop;
- var results = _isArrayLike(tasks) ? [] : {};
-
- async.eachOfSeries(tasks, function (task, key, callback) {
- task(_restParam(function (err, args) {
- if (args.length <= 1) {
- args = args[0];
- }
- results[key] = args;
- callback(err);
- }));
- }, function (err) {
- callback(err, results);
- });
+ async.series = function(tasks, callback) {
+ _parallel(async.eachOfSeries, tasks, callback);
};
async.iterator = function (tasks) {