Lines Matching refs:cargo

1725  * Creates a `cargo` object with the specified payload. Tasks added to the
1726  * cargo will be processed altogether (up to the `payload` limit). If the
1730  * for how `cargo` and `queue` work.
1733  * at a time, cargo passes an array of tasks to a single worker, repeating
1736  * @name cargo
1747  * @returns {module:ControlFlow.QueueObject} A cargo object to manage the tasks. Callbacks can
1749  * lifecycle of the cargo and inner queue.
1752  * // create a cargo object with payload 2
1753  * var cargo = async.cargo(function(tasks, callback) {
1761  * cargo.push({name: 'foo'}, function(err) {
1764  * cargo.push({name: 'bar'}, function(err) {
1767  * await cargo.push({name: 'baz'});
1770 function cargo(worker, payload) {  function
1780  * for how `cargo` and `queue` work.
1783 …* at a time, and [`cargo`]{@link module:ControlFlow.cargo} passes an array of tasks to a single wo…
1791  * @see [async.cargo]{@link module:ControlFLow.cargo}
1828 function cargo$1(worker, concurrency, payload) {
3884  * [cargo]{@link module:ControlFlow.cargo} object
5845     cargo,
5846     cargoQueue: cargo$1,
5947 export { apply, applyEach$1 as applyEach, applyEachSeries, asyncify, auto, autoInject, cargo, cargo…