|
217 | 217 | }) |
218 | 218 | } |
219 | 219 |
|
220 | | - Object.defineProperty(awaitable, 'name', { |
221 | | - configurable: true, // allows redefining |
222 | | - value: `awaitable(${asyncFn.name})` |
223 | | - }); |
224 | | - |
225 | 220 | return awaitable |
226 | 221 | } |
227 | 222 |
|
|
1557 | 1552 | * @param {number} [payload=Infinity] - An optional `integer` for determining |
1558 | 1553 | * how many tasks should be processed per round; if omitted, the default is |
1559 | 1554 | * unlimited. |
1560 | | - * @returns {module:ControlFlow.CargoObject} A cargoQueue object to manage the tasks. Callbacks can |
| 1555 | + * @returns {module:ControlFlow.QueueObject} A cargoQueue object to manage the tasks. Callbacks can |
1561 | 1556 | * attached as certain properties to listen for specific events during the |
1562 | 1557 | * lifecycle of the cargoQueue and inner queue. |
1563 | 1558 | * @example |
|
2946 | 2941 |
|
2947 | 2942 | var nextTick = wrap(_defer$1); |
2948 | 2943 |
|
2949 | | - var _parallel = awaitify((eachfn, tasks, callback) => { |
| 2944 | + var parallel = awaitify((eachfn, tasks, callback) => { |
2950 | 2945 | var results = isArrayLike(tasks) ? [] : {}; |
2951 | 2946 |
|
2952 | 2947 | eachfn(tasks, (task, key, taskCb) => { |
|
3030 | 3025 | * // results is now equals to: {one: 1, two: 2} |
3031 | 3026 | * }); |
3032 | 3027 | */ |
3033 | | - function parallel(tasks, callback) { |
3034 | | - return _parallel(eachOf$1, tasks, callback); |
| 3028 | + function parallel$1(tasks, callback) { |
| 3029 | + return parallel(eachOf$1, tasks, callback); |
3035 | 3030 | } |
3036 | 3031 |
|
3037 | 3032 | /** |
|
3055 | 3050 | * @returns {Promise} a promise, if a callback is not passed |
3056 | 3051 | */ |
3057 | 3052 | function parallelLimit(tasks, limit, callback) { |
3058 | | - return _parallel(eachOfLimit(limit), tasks, callback); |
| 3053 | + return parallel(eachOfLimit(limit), tasks, callback); |
3059 | 3054 | } |
3060 | 3055 |
|
3061 | 3056 | /** |
|
3959 | 3954 | * }); |
3960 | 3955 | */ |
3961 | 3956 | function series(tasks, callback) { |
3962 | | - return _parallel(eachOfSeries$1, tasks, callback); |
| 3957 | + return parallel(eachOfSeries$1, tasks, callback); |
3963 | 3958 | } |
3964 | 3959 |
|
3965 | 3960 | /** |
|
4433 | 4428 | * |
4434 | 4429 | * var count = 0; |
4435 | 4430 | * async.whilst( |
4436 | | - * function test(cb) { cb(null, count < 5;) }, |
| 4431 | + * function test(cb) { cb(null, count < 5); }, |
4437 | 4432 | * function iter(callback) { |
4438 | 4433 | * count++; |
4439 | 4434 | * setTimeout(function() { |
|
4494 | 4489 | * |
4495 | 4490 | * @example |
4496 | 4491 | * const results = [] |
| 4492 | + * let finished = false |
4497 | 4493 | * async.until(function test(page, cb) { |
4498 | | - * cb(null, page.next == null) |
| 4494 | + * cb(null, finished) |
4499 | 4495 | * }, function iter(next) { |
4500 | 4496 | * fetchPage(url, (err, body) => { |
4501 | 4497 | * if (err) return next(err) |
4502 | 4498 | * results = results.concat(body.objects) |
4503 | | - * next(err, body) |
| 4499 | + * finished = !!body.next |
| 4500 | + * next(err) |
4504 | 4501 | * }) |
4505 | 4502 | * }, function done (err) { |
4506 | 4503 | * // all pages have been fetched |
|
4677 | 4674 | mapValuesSeries, |
4678 | 4675 | memoize, |
4679 | 4676 | nextTick, |
4680 | | - parallel, |
| 4677 | + parallel: parallel$1, |
4681 | 4678 | parallelLimit, |
4682 | 4679 | priorityQueue, |
4683 | 4680 | queue: queue$1, |
|
4785 | 4782 | exports.mapValuesSeries = mapValuesSeries; |
4786 | 4783 | exports.memoize = memoize; |
4787 | 4784 | exports.nextTick = nextTick; |
4788 | | - exports.parallel = parallel; |
| 4785 | + exports.parallel = parallel$1; |
4789 | 4786 | exports.parallelLimit = parallelLimit; |
4790 | 4787 | exports.priorityQueue = priorityQueue; |
4791 | 4788 | exports.queue = queue$1; |
|
0 commit comments