async/lib/mapLimit.js at gh-pages · againksy/async

Repository navigation

import doParallelLimit from './internal/doParallelLimit';

import map from './internal/map';

/**

* The same as [`map`]{@link module:Collections.map} but runs a maximum of `limit` async operations at a time.

* @name mapLimit

* @static

* @memberOf module:Collections

* @method

* @see [async.map]{@link module:Collections.map}

* @category Collection

* @param {Array|Iterable|Object} coll - A collection to iterate over.

* @param {number} limit - The maximum number of async operations at a time.

* @param {Function} iteratee - A function to apply to each item in `coll`.

* The iteratee is passed a `callback(err, transformed)` which must be called

* once it has completed with an error (which can be `null`) and a transformed

* item. Invoked with (item, callback).

* @param {Function} [callback] - A callback which is called when all `iteratee`

* functions have finished, or an error occurs. Results is an array of the

* transformed items from the `coll`. Invoked with (err, results).

export default doParallelLimit(map);