Function assertUnhandledPipePromise

test/pipe/sequence.js:34–46

(t, {destinationOptions = {}, inspectPipePromise} = {})

};

const assertUnhandledPipePromise = async (t, {destinationOptions = {}, inspectPipePromise} = {}) => {
	const source = execa('fail.js');
	const destination = execa('fail.js', destinationOptions);
	const pipePromise = source.pipe(destination);
	const unhandledRejectionPromise = once(process, 'unhandledRejection');
	await inspectPipePromise?.(pipePromise);
	await assertUnhandledRejection(t, pipePromise, unhandledRejectionPromise);
	await Promise.all([
		t.throwsAsync(source),
		t.throwsAsync(destination),
	]);
	await t.throwsAsync(pipePromise);
};

test('Source stream abort -> destination success', async t => {
	const source = execa('noop-repeat.js');