Function read

test-src/JsonStreamStringify.spec.ts:434–451

()

    let ended = false;
    read();
    function read() {
      if (a.readableEnded) return;
      for (let i = 0; i < 10; i++) {
        a._read(); // simulate bad forced read
        a.read(); // legitimate read call
        a._read(); // simulate bad forced read
        if (!(p.writableEnded || ended) && i === 8) p.write(c++);
        a._read(); // simulate bad forced read
      }
      if (!(p.writableEnded || ended) && c > 3) {
        ended = true;
        p.end();
        // p.read();
        setTimeout(read, 10);
        return;
      }
      setImmediate(read);
    }
  });

  it('prePush', (cb) => {