Lines Matching refs:readable
57 const readable = new Readable({ autoDestroy: false, read() {} });
58 readable.push('asd');
59 readable.push('asd');
60 readable.destroy = null;
61 readable.close = common.mustCall(() => {
62 readable.emit('close');
66 for await (const d of readable) {
73 const readable = new Readable({ objectMode: true, read() {} });
74 readable.push(0);
75 readable.push(1);
76 readable.push(null);
78 const iter = readable[Symbol.asyncIterator]();
88 const readable = new Readable({
93 const iter = readable[Symbol.asyncIterator]();
94 assert.strictEqual(iter.stream, readable);
104 readable.push('hello-0');
105 readable.push('hello-1');
106 readable.push('hello-2');
107 readable.push('hello-3');
108 readable.push('hello-4');
109 readable.push(null);
117 const readable = new Readable({
122 const iter = readable[Symbol.asyncIterator]();
123 assert.strictEqual(iter.stream, readable);
129 readable.push('hello-0');
130 readable.push('hello-1');
131 readable.push('hello-2');
143 readable.push('hello-3');
144 readable.push('hello-4');
145 readable.push(null);
158 const readable = new Readable({
163 const iter = readable[Symbol.asyncIterator]();
164 assert.strictEqual(iter.stream, readable);
175 readable.push('hello-0');
176 readable.push('hello-1');
177 readable.push('hello-2');
197 readable.destroy(new Error('kaboom'));
202 const readable = new Readable({
205 const iterator = readable[Symbol.asyncIterator]();
208 readable.destroy(err);
217 const readable = new Readable({
227 for await (const k of readable) {
237 const readable = new Readable({
247 for await (const k of readable) { }
256 const readable = new Readable({
275 for await (const k of readable) {
288 const readable = new Readable({
297 for await (const k of readable) {
306 assert.strictEqual(readable.destroyed, true);
311 const readable = new Readable({
323 for await (const k of readable) {
337 const readable = new Readable();
338 readable.destroy();
340 readable.on('close', common.mustNotCall());
344 for await (const k of readable) {
362 const readable = new Readable({
374 for await (const k of readable) {
386 const readable = new Readable({
398 readable.setEncoding('utf8');
399 readable.pause();
400 readable.on('data', (chunk) => {
405 for await (const k of readable) {
414 const readable = new Readable({
420 readable.destroy();
422 const it = await readable[Symbol.asyncIterator]();
433 const readable = new Readable({
441 pipeline(readable, passthrough, common.mustCall((e) => {
444 readable.destroy(err);
446 readable[Symbol.asyncIterator]().next(),
493 console.log('readable side of a transform stream pushes null');
721 const readable = fs.createReadStream(__filename);
725 for await (const chunk of readable) {
726 readable.close();
734 assert.ok(readable.destroyed);
752 const readable = createReadable();
753 for await (const chunk of readable.iterator({ destroyOnReturn: true })) {
758 assert.ok(readable.destroyed);
763 const readable = createReadable();
765 for await (const chunk of readable.iterator(opts)) {
770 assert.ok(!readable.destroyed);
772 for await (const chunk of readable.iterator(opts)) {
776 assert.ok(readable.destroyed);
781 const readable = createReadable();
783 () => readable.iterator(42),
795 const readable = createReadable();
797 while (readable.readable) {
799 for await (const chunk of readable.iterator(opts)) {
804 assert.deepStrictEqual(readable.eventNames(), []);