如何克隆NodeJS流？

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

class CloneStream extends Duplex {
  _read(size) {
    // 实现读取逻辑
  }

  _write(chunk, encoding, callback) {
    // 实现写入逻辑
  }
}

_read(size) {
  // 从源流读取数据
  const data = readDataFromSource(size);

  // 将数据推送到克隆流中
  this.push(data);
}

_write(chunk, encoding, callback) {
  // 将数据写入目标位置
  writeDataToDestination(chunk);

  // 完成写入操作后调用回调函数
  callback();
}

const sourceStream = createSourceStream();
const cloneStream = new CloneStream();

sourceStream.pipe(cloneStream);