summaryrefslogtreecommitdiff
path: root/lib/async.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/async.js')
-rw-r--r--lib/async.js12
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) {