diff options
Diffstat (limited to 'lib/async.js')
-rw-r--r-- | lib/async.js | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/lib/async.js b/lib/async.js index f6ef7c1..cbd2678 100644 --- a/lib/async.js +++ b/lib/async.js @@ -335,8 +335,8 @@ return fn(async.eachOf, obj, iterator, callback); }; } - function doParallelLimit(limit, fn) { - return function (obj, iterator, callback) { + function doParallelLimit(fn) { + return function (obj, limit, iterator, callback) { return fn(_eachOfLimit(limit), obj, iterator, callback); }; } @@ -361,9 +361,7 @@ async.map = doParallel(_asyncMap); async.mapSeries = doSeries(_asyncMap); - async.mapLimit = function (arr, limit, iterator, callback) { - return doParallelLimit(limit, _asyncMap)(arr, iterator, callback); - }; + async.mapLimit = doParallelLimit(_asyncMap); // reduce only has a series version, as doing reduce in parallel won't // work in many situations. @@ -409,6 +407,9 @@ async.select = async.filter = doParallel(_filter); + async.selectLimit = + async.filterLimit = doParallelLimit(_filter); + async.selectSeries = async.filterSeries = doSeries(_filter); @@ -420,6 +421,7 @@ }, callback); } async.reject = doParallel(_reject); + async.rejectLimit = doParallelLimit(_reject); async.rejectSeries = doSeries(_reject); function _createTester(eachfn, check, getResult) { |