Function assertCanceledPipeReader

test/pipe/methods.js:378–398

(t, getReader, shouldAbortBeforePipe = false)

});

const assertCanceledPipeReader = async (t, getReader, shouldAbortBeforePipe = false) => {
	const abortController = new AbortController();
	if (shouldAbortBeforePipe) {
		abortController.abort();
	}

	const source = execa('stdin.js');
	const destination = execa('stdin.js', {all: true});
	t.teardown(async () => {
		await cleanupSubprocesses(source, destination);
	});

	const piped = source.pipe(destination, {unpipeSignal: abortController.signal});
	const readerPromise = t.throwsAsync(getReader(piped), {message: /Pipe canceled/});

	if (!shouldAbortBeforePipe) {
		abortController.abort();
	}

	await assertSettles(t, readerPromise, 200);
};

test('The .pipe() return value .readable() waits for pipe cancellation', async t => {
	await assertCanceledPipeReader(t, piped => text(piped.readable()));