123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113 |
- 'use strict';
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.default = function (tasks, callback) {
- callback = (0, _once2.default)(callback || _noop2.default);
- if (!(0, _isArray2.default)(tasks)) return callback(new Error('First argument to waterfall must be an array of functions'));
- if (!tasks.length) return callback();
- var taskIndex = 0;
- function nextTask(args) {
- var task = (0, _wrapAsync2.default)(tasks[taskIndex++]);
- args.push((0, _onlyOnce2.default)(next));
- task.apply(null, args);
- }
- function next(err ) {
- if (err || taskIndex === tasks.length) {
- return callback.apply(null, arguments);
- }
- nextTask((0, _slice2.default)(arguments, 1));
- }
- nextTask([]);
- };
- var _isArray = require('lodash/isArray');
- var _isArray2 = _interopRequireDefault(_isArray);
- var _noop = require('lodash/noop');
- var _noop2 = _interopRequireDefault(_noop);
- var _once = require('./internal/once');
- var _once2 = _interopRequireDefault(_once);
- var _slice = require('./internal/slice');
- var _slice2 = _interopRequireDefault(_slice);
- var _onlyOnce = require('./internal/onlyOnce');
- var _onlyOnce2 = _interopRequireDefault(_onlyOnce);
- var _wrapAsync = require('./internal/wrapAsync');
- var _wrapAsync2 = _interopRequireDefault(_wrapAsync);
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- module.exports = exports['default'];
|