Diffusion Ant (master) Code

ant/tests/test_stream_static_state_predicates.cjs
e35c3ed2ab40master

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');
			});

Owner Packages

No Owners