test_stream_is_disturbed_end.cjs
No OneTemporary
Actions

Size

880 B

Referenced Files

None

Subscribers

None

test_stream_is_disturbed_end.cjs
View Options

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

	async function endedWithoutDataIsReusable() {
	const readable = new stream.Readable({ read() {} });
	const ended = new Promise((resolve) => readable.once('end', resolve));

	readable.resume();
	readable.push(null);
	await ended;

	assert.strictEqual(readable._readableState.endEmitted, true);
	assert.strictEqual(stream.isDisturbed(readable), false);
	}

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

	assert.strictEqual(stream.isDisturbed(readable), false);
	assert.strictEqual(readable.read().toString(), 'ok');
	assert.strictEqual(stream.isDisturbed(readable), true);
	}

	endedWithoutDataIsReusable().then(() => {
	readingDataDisturbs();
	console.log('stream:is-disturbed-end:ok');
	});

File Metadata

Mime Type: application/javascript
Expires: Sun, May 17, 5:47 AM (2 d)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 554553
Default Alt Text: test_stream_is_disturbed_end.cjs (880 B)

Event Timeline