test_stream_is_errored.cjs
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

test_stream_is_errored.cjs
View Options

	const assert = require('node:assert');
	const stream = require('node:stream');

	function tick() {
	return new Promise((resolve) => setImmediate(resolve));
	}

	(async () => {
	{
	const err = new Error('readable boom');
	const readable = new stream.Readable({ read() {} });
	readable.on('error', () => {});

	assert.strictEqual(stream.isErrored(readable), false);
	readable.destroy(err);
	assert.strictEqual(readable._readableState.errored, err);
	await tick();
	assert.strictEqual(stream.isErrored(readable), true);
	}

	{
	const err = new Error('writable boom');
	const writable = new stream.Writable({
	write(_chunk, _encoding, callback) {
	callback(err);
	},
	});
	writable.on('error', () => {});

	assert.strictEqual(stream.isErrored(writable), false);
	writable.write('x', () => {});
	assert.strictEqual(writable._writableState.errored, err);
	await tick();
	assert.strictEqual(stream.isErrored(writable), true);
	}

	console.log('stream-is-errored:ok');
	})().catch((err) => {
	console.error(err && err.stack ? err.stack : String(err));
	process.exit(1);
	});