管道中的流错误处理 - 停止前一个流

Question

我正在尝试使用管道函数正确处理错误事件。

假设我在 Promise 中有两个流 A（转换 stream.passThrough()）和 B(writeStream)，代码如下：

new Promise( (resolve, reject) => {
               A.pipe(B).on('error', (err)=>{reject})
                         .on('end', ()=>{resolve})})

上面的代码按预期拒绝了承诺，但是流 A 继续工作。有人可以建议我如何阻止流 A 流动吗？

Answer 1

发生错误时您可以销毁流 A：

transform.destroy([error]) 销毁流，并发出“错误”。在此调用之后，转换流将释放任何内部资源。实现者不应重写此方法，而应实现 readable._destroy()。 Transform 的 _destroy() 的默认实现也会发出 'close'。

编辑

new Promise( (resolve, reject) => {
               A.pipe(B).on('error', err => { A.destroy(); reject(err); })
                         .on('end',    e => { resolve(e) })
})