blob: 5b621508c2b30aabd3f14beff3a564f2255eecb6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
'use strict';
import eachOfLimit from './internal/eachOfLimit';
import parallel from './internal/parallel';
/**
* The same as `parallel` but runs a maximum of `limit` async operations at a
* time.
*
* @name parallel
* @static
* @memberOf async
* @see async.parallel
* @category Control Flow
* @param {Array|Collection} tasks - A collection containing functions to run.
* Each function is passed a `callback(err, result)` which it must call on
* completion with an error `err` (which can be `null`) and an optional `result`
* value.
* @param {number} limit - The maximum number of async operations at a time.
* @param {Function} [callback] - An optional callback to run once all the
* functions have completed successfully. This function gets a results array
* (or object) containing all the result arguments passed to the task callbacks.
* Invoked with (err, results).
*/
export default function parallelLimit(tasks, limit, cb) {
return parallel(eachOfLimit(limit), tasks, cb);
}
|
