node.js 输入输出流

const fs = require('fs');

// 创建一个可读流
const readStream = fs.createReadStream('source.txt');

// 创建一个可写流
const writeStream = fs.createWriteStream('destination.txt');

// 将可读流的数据通过管道传输到可写流
readStream.pipe(writeStream);

writeStream.on('finish', () => {
  console.log('文件复制完成');
});

writeStream.on('error', (err) => {
  console.error('发生错误:', err);
});

readStream.on('end', () => {
  console.log('读取完成');
});

readStream.on('error', (err) => {
  console.error('读取错误:', err);
});

writeStream.on('finish', () => {
  console.log('写入完成');
});

writeStream.on('error', (err) => {
  console.error('写入错误:', err);
});

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

const transformStream = new PassThrough({ highWaterMark: 1024 * 1024 }); // 设置缓冲区大小为1MB