1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
// 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 { Readable, PassThrough } = require('stream');
function test(r) {  const wrapper = new Readable({    read: () => {      let data = r.read();
      if (data) {        wrapper.push(data);        return;      }
      r.once('readable', function() {        data = r.read();        if (data) {          wrapper.push(data);        }        // else: the end event should fire      });    },  });
  r.once('end', function() {    wrapper.push(null);  });
  wrapper.resume();  wrapper.once('end', common.mustCall());}
{  const source = new Readable({    read: () => {}  });  source.push('foo');  source.push('bar');  source.push(null);
  const pt = source.pipe(new PassThrough());  test(pt);}
{  // This is the underlying cause of the above test case.  const pushChunks = ['foo', 'bar'];  const r = new Readable({    read: () => {      const chunk = pushChunks.shift();      if (chunk) {        // synchronous call        r.push(chunk);      } else {        // asynchronous call        process.nextTick(() => r.push(null));      }    },  });
  test(r);}