diff options
author | Alexander Early <alexander.early@gmail.com> | 2015-07-02 00:36:26 -0700 |
---|---|---|
committer | Alexander Early <alexander.early@gmail.com> | 2015-07-02 00:36:26 -0700 |
commit | ea84790dac32cfebec2dfcf57533258a42d0d335 (patch) | |
tree | 2359a28f366ba0ff1fdde746dffc90c73ff966f0 | |
parent | ac170ba5a22a7b8ffaf03ad638e8857fe7150d86 (diff) | |
parent | 5fdc96a66f59b9deca1780ec3f53c4a0111c262a (diff) | |
download | async-ea84790dac32cfebec2dfcf57533258a42d0d335.tar.gz |
Merge pull request #821 from megawac/series-parallel
Implement series via _parallel
-rw-r--r-- | lib/async.js | 17 |
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) { |