Function test

test/parallel/test-stream-readable-no-unneeded-readable.js:5–31

(r)

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({