Node.js Stream transform.destroy() 方法

在 Node.js 中，transform.destroy() 方法用于摧毁一个可写流和一个可读流的实例。它将立即停止流，并清空所有缓冲内容。它也会触发一个 finish 事件和一个 close 事件。

语法

transform.destroy([error])

error 参数是一个可选的错误对象，如果提供了它，将会触发一个 error 事件。

示例

以下是一个使用 transform.destroy() 的简单示例，它创建一个可写流和一个可读流，并使用管道将数据从可读流传输到可写流：

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

const myTransform = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

const readable = new Readable({
  read() {
    this.push('hello world');
    this.push(null);
  }
});

const writable = new Writable({
  write(chunk, encoding, callback) {
    console.log(chunk.toString());
    callback();
  }
});

readable.pipe(myTransform).pipe(writable);

// 调用 destroy 来停止流
myTransform.destroy();

在上面的示例中，我们定义了一个转换流 myTransform，它将传入的数据转换成大写字母，并将其传递给可写流 writable。然后，我们创建一个可读流 readable，它会发送一条消息 hello world。最后，我们通过管道将可读流传输到转换流中，并将转换流传输到可写流中。最后，我们立即调用 myTransform.destroy() 来停止流。

总结

transform.destroy() 方法在关闭一个流时非常有用，它可以立即停止流，并清空所有缓冲内容。它还可以触发 finish 和 close 事件。如果你的应用程序需要手动停止流，那么 transform.destroy() 方法就是一个非常有用的工具。