source: trip-planner-front/node_modules/async/waterfall.js@ 76712b2

Last change on this file since 76712b2 was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 3.3 KB
Line 
1'use strict';
2
3Object.defineProperty(exports, "__esModule", {
4 value: true
5});
6
7exports.default = function (tasks, callback) {
8 callback = (0, _once2.default)(callback || _noop2.default);
9 if (!(0, _isArray2.default)(tasks)) return callback(new Error('First argument to waterfall must be an array of functions'));
10 if (!tasks.length) return callback();
11 var taskIndex = 0;
12
13 function nextTask(args) {
14 var task = (0, _wrapAsync2.default)(tasks[taskIndex++]);
15 args.push((0, _onlyOnce2.default)(next));
16 task.apply(null, args);
17 }
18
19 function next(err /*, ...args*/) {
20 if (err || taskIndex === tasks.length) {
21 return callback.apply(null, arguments);
22 }
23 nextTask((0, _slice2.default)(arguments, 1));
24 }
25
26 nextTask([]);
27};
28
29var _isArray = require('lodash/isArray');
30
31var _isArray2 = _interopRequireDefault(_isArray);
32
33var _noop = require('lodash/noop');
34
35var _noop2 = _interopRequireDefault(_noop);
36
37var _once = require('./internal/once');
38
39var _once2 = _interopRequireDefault(_once);
40
41var _slice = require('./internal/slice');
42
43var _slice2 = _interopRequireDefault(_slice);
44
45var _onlyOnce = require('./internal/onlyOnce');
46
47var _onlyOnce2 = _interopRequireDefault(_onlyOnce);
48
49var _wrapAsync = require('./internal/wrapAsync');
50
51var _wrapAsync2 = _interopRequireDefault(_wrapAsync);
52
53function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
54
55module.exports = exports['default'];
56
57/**
58 * Runs the `tasks` array of functions in series, each passing their results to
59 * the next in the array. However, if any of the `tasks` pass an error to their
60 * own callback, the next function is not executed, and the main `callback` is
61 * immediately called with the error.
62 *
63 * @name waterfall
64 * @static
65 * @memberOf module:ControlFlow
66 * @method
67 * @category Control Flow
68 * @param {Array} tasks - An array of [async functions]{@link AsyncFunction}
69 * to run.
70 * Each function should complete with any number of `result` values.
71 * The `result` values will be passed as arguments, in order, to the next task.
72 * @param {Function} [callback] - An optional callback to run once all the
73 * functions have completed. This will be passed the results of the last task's
74 * callback. Invoked with (err, [results]).
75 * @returns undefined
76 * @example
77 *
78 * async.waterfall([
79 * function(callback) {
80 * callback(null, 'one', 'two');
81 * },
82 * function(arg1, arg2, callback) {
83 * // arg1 now equals 'one' and arg2 now equals 'two'
84 * callback(null, 'three');
85 * },
86 * function(arg1, callback) {
87 * // arg1 now equals 'three'
88 * callback(null, 'done');
89 * }
90 * ], function (err, result) {
91 * // result now equals 'done'
92 * });
93 *
94 * // Or, with named functions:
95 * async.waterfall([
96 * myFirstFunction,
97 * mySecondFunction,
98 * myLastFunction,
99 * ], function (err, result) {
100 * // result now equals 'done'
101 * });
102 * function myFirstFunction(callback) {
103 * callback(null, 'one', 'two');
104 * }
105 * function mySecondFunction(arg1, arg2, callback) {
106 * // arg1 now equals 'one' and arg2 now equals 'two'
107 * callback(null, 'three');
108 * }
109 * function myLastFunction(arg1, callback) {
110 * // arg1 now equals 'three'
111 * callback(null, 'done');
112 * }
113 */
Note: See TracBrowser for help on using the repository browser.