send/server/streamparser.js

const { Duplex } = require('stream');

class StreamParser extends Duplex {
  _write(chunk, encoding, callback) {
    if (chunk.byteLength === 1 && chunk[0] === 0) {
      this.push(null);
    } else {
      this.push(chunk);
    }
    callback();
  }
  _read() {}
}

module.exports = StreamParser;