12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
// 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);}