Error are not triggered

[leecjson]

Please see 'end-of-stream' module's second param options,

eos(stream, {readable: reading, writable: writing}, function (err) {
    if (err) return callback(err)
    closed = true
    callback()
  })

can you change the codes to

eos(stream, {readable: reading, writable: writing, error: true}, function (err) {
    if (err) return callback(err)
    closed = true
    callback()
  })

[mafintosh]

I’m not sure what you are asking about. Can you clarify?

[leecjson]

pump(
      tar.create({
        zlib: { level: 9 },
        cwd: output,
      }, fs.readdirSync(output)),
      req,
      (err) => {
        if (err) {
          reject(err);
        }
      });

The codes above will not reject when 'req' (which req is a http.request) emit a 'hang up error', So i have to change the codes to

tarStream
      .on('error', e => {
        req.destroy();
        reject(e);
      })
      .pipe(req)
      .on('error', e => {
        tarStream.destroy();
        reject(e);
      });