deno.land / std@0.166.0 / node / _tools / test / parallel / test-stream-readable-didRead.js
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 18.12.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
'use strict';const common = require('../common');const assert = require('assert');const { isDisturbed, isErrored, Readable } = require('stream');
function noop() {}
function check(readable, data, fn) { assert.strictEqual(readable.readableDidRead, false); assert.strictEqual(isDisturbed(readable), false); assert.strictEqual(isErrored(readable), false); if (data === -1) { readable.on('error', common.mustCall(() => { assert.strictEqual(isErrored(readable), true); })); readable.on('data', common.mustNotCall()); readable.on('end', common.mustNotCall()); } else { readable.on('error', common.mustNotCall()); if (data === -2) { readable.on('end', common.mustNotCall()); } else { readable.on('end', common.mustCall()); } if (data > 0) { readable.on('data', common.mustCallAtLeast(data)); } else { readable.on('data', common.mustNotCall()); } } readable.on('close', common.mustCall()); fn(); setImmediate(() => { assert.strictEqual(readable.readableDidRead, data > 0); if (data > 0) { assert.strictEqual(isDisturbed(readable), true); } });}
{ const readable = new Readable({ read() { this.push(null); } }); check(readable, 0, () => { readable.read(); });}
{ const readable = new Readable({ read() { this.push(null); } }); check(readable, 0, () => { readable.resume(); });}
{ const readable = new Readable({ read() { this.push(null); } }); check(readable, -2, () => { readable.destroy(); });}
{ const readable = new Readable({ read() { this.push(null); } });
check(readable, -1, () => { readable.destroy(new Error()); });}
{ const readable = new Readable({ read() { this.push('data'); this.push(null); } });
check(readable, 1, () => { readable.on('data', noop); });}
{ const readable = new Readable({ read() { this.push('data'); this.push(null); } });
check(readable, 1, () => { readable.on('data', noop); readable.off('data', noop); });}
Version Info