Function flow

test/parallel/test-stream2-readable-wrap.js:60–71

()

  let oldEnded = false;
  const expected = [];
  function flow() {
    flowing = true;
    while (flowing && chunks-- > 0) {
      const item = produce();
      expected.push(item);
      old.emit('data', item);
    }
    if (chunks <= 0) {
      oldEnded = true;
      old.emit('end');
    }
  }

  const w = new Writable({ highWaterMark: highWaterMark * 2,
                           objectMode });