Spaces:
Running
Running
| /* | |
| MIT License http://www.opensource.org/licenses/mit-license.php | |
| Author Tobias Koppers @sokra | |
| */ | |
| ; | |
| const Hook = require("./Hook"); | |
| const HookCodeFactory = require("./HookCodeFactory"); | |
| class AsyncSeriesWaterfallHookCodeFactory extends HookCodeFactory { | |
| content({ onError, onResult, _onDone }) { | |
| return this.callTapsSeries({ | |
| onError: (i, err, next, doneBreak) => onError(err) + doneBreak(true), | |
| onResult: (i, result, next) => { | |
| let code = ""; | |
| code += `if(${result} !== undefined) {\n`; | |
| code += `${this._args[0]} = ${result};\n`; | |
| code += "}\n"; | |
| code += next(); | |
| return code; | |
| }, | |
| onDone: () => onResult(this._args[0]) | |
| }); | |
| } | |
| } | |
| const factory = new AsyncSeriesWaterfallHookCodeFactory(); | |
| function COMPILE(options) { | |
| factory.setup(this, options); | |
| return factory.create(options); | |
| } | |
| function AsyncSeriesWaterfallHook(args = [], name = undefined) { | |
| if (args.length < 1) { | |
| throw new Error("Waterfall hooks must have at least one argument"); | |
| } | |
| const hook = new Hook(args, name); | |
| hook.constructor = AsyncSeriesWaterfallHook; | |
| hook.compile = COMPILE; | |
| hook._call = undefined; | |
| hook.call = undefined; | |
| return hook; | |
| } | |
| AsyncSeriesWaterfallHook.prototype = null; | |
| module.exports = AsyncSeriesWaterfallHook; | |