pool

  .getConnection()

  .then(conn => {

    const someWriterStream = fs.createWriteStream("./tmp.file")

      .on("error", err => {

        //export has ended, resume stream

        queryStream.resume();

      });

    const transform = new Transform({

      transform: function transformer(chunk, encoding, callback) {

        callback(null, JSON.stringify(chunk));

      },

      objectMode: true

    });

    const queryStream = conn.queryStream("SELECT seq as val FROM seq_1_to_10000");

    queryStream

      .pipe(transform)

      .pipe(someWriterStream)

      .on('close', () => {

        conn.end();

      });

    //forcing a WRITER end to simulate this error

    setTimeout(someWriterStream.destroy.bind(someWriterStream), 2);

  })

  .catch(err => {

    //error

  });