Function assertCanceledPipeMessageReader

test/pipe/methods.js:219–240

(t, getReader, shouldAbortBeforePipe = false)

});

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

	const source = execa('noop-repeat.js');
	const destination = execa('ipc-get.js', {ipc: 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);
	await t.throwsAsync(piped, {message: /Pipe canceled/});
};

test('The .pipe() return value .getEachMessage() waits for pipe cancellation before IPC messages', async t => {
	await assertCanceledPipeMessageReader(t, piped => piped.getEachMessage().next());