stream._read = () => {
        let chunk = null;

        if (chunks.length) {
          chunk = chunks.shift();