|
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