Method callTapsSeries

lib/HookCodeFactory.js:283–335

({
		onError,
		onResult,
		resultReturns,
		onDone,
		doneReturns,
		rethrowIfPossible
	})

	}

	callTapsSeries({
		onError,
		onResult,
		resultReturns,
		onDone,
		doneReturns,
		rethrowIfPossible
	}) {
		const { taps } = this.options;
		const tapsLength = taps.length;
		if (tapsLength === 0) return onDone();
		// Inlined findIndex to avoid the callback allocation.
		let firstAsync = -1;
		for (let i = 0; i < tapsLength; i++) {
			if (taps[i].type !== "sync") {
				firstAsync = i;
				break;
			}
		}
		const somethingReturns = resultReturns || doneReturns;
		// doneBreak doesn't depend on the loop variable - hoist to allocate once.
		const doneBreak = (skipDone) => {
			if (skipDone) return "";
			return onDone();
		};
		let code = "";
		let current = onDone;
		let unrollCounter = 0;
		for (let j = tapsLength - 1; j >= 0; j--) {
			const i = j;
			const unroll =
				current !== onDone && (taps[i].type !== "sync" || unrollCounter++ > 20);
			if (unroll) {
				unrollCounter = 0;
				code += `function _next${i}() {\n`;
				code += current();
				code += "}\n";
				current = () => `${somethingReturns ? "return " : ""}_next${i}();\n`;
			}
			const done = current;
			const content = this.callTap(i, {
				onError: (error) => onError(i, error, done, doneBreak),
				onResult:
					onResult && ((result) => onResult(i, result, done, doneBreak)),
				onDone: !onResult && done,
				rethrowIfPossible:
					rethrowIfPossible && (firstAsync < 0 || i < firstAsync)
			});
			current = () => content;
		}
		code += current();
		return code;
	}

	callTapsLooping({ onError, onDone, rethrowIfPossible }) {
		if (this.options.taps.length === 0) return onDone();