test_stream_static_state_predicates.cjs
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

test_stream_static_state_predicates.cjs
View Options

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

	async function endedReadableReportsFalse() {
	const readable = new stream.Readable({
	read() {
	this.push(Buffer.from('ok'));
	this.push(null);
	}
	});

	assert.strictEqual(stream.isReadable(readable), true);
	assert.strictEqual(stream.isErrored(readable), false);
	assert.strictEqual(stream.isDestroyed(readable), false);
	assert.strictEqual(stream.isDisturbed(readable), false);

	readable.resume();
	await new Promise((resolve) => readable.once('end', resolve));
	assert.strictEqual(readable.readableEnded, true);
	assert.strictEqual(stream.isReadable(readable), false);
	}

	function destroyedReadableReportsFalse() {
	const readable = new stream.Readable({
	read() {
	this.push(Buffer.from('ok'));
	this.push(null);
	}
	});

	readable.destroy();
	assert.strictEqual(stream.isDestroyed(readable), true);
	assert.strictEqual(stream.isReadable(readable), false);
	}

	endedReadableReportsFalse().then(() => {
	destroyedReadableReportsFalse();
	console.log('stream:static-state-predicates:ok');
	});