如何构造损坏的流以测试streamToString函数的error事件处理逻辑

你可以通过构造主动抛出error事件的流来触发对应分支，常用的两种实现方式如下：

方案1：单元测试用可控模拟流（推荐，适合单测覆盖率统计场景） #

直接基于Node.js内置的stream.Readable构造自定义流，在流读取阶段主动抛出错误，示例代码：

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

// 构造会触发error事件的测试流
const testErrorStream = new Readable({
  read() {
    // 主动触发error事件
    this.emit('error', new Error('自定义流测试错误'));
  }
});

// 测试你的目标函数
streamToString(testErrorStream)
  .then(() => console.log('不会进入该分支'))
  .catch(err => {
    console.log('成功触发error回调分支，错误信息：', err.message);
  });

该方案完全可控，不需要依赖任何外部资源，单测中可以直接使用。

方案2：真实业务流触发 #

如果需要测试真实场景的错误，可使用常规业务流的错误触发逻辑，示例如下：

• 文件流场景：读取不存在的文件路径，文件流会自动抛出error事件

const fs = require('fs');
// 传入指向不存在路径的文件流
const notExistFileStream = fs.createReadStream('/non/existent/file/path.txt');
streamToString(notExistFileStream)
  .catch(err => console.log('触发文件流错误：', err.message));

• 网络流场景：请求不可达的HTTP地址，拿到的响应流也会抛出error事件，用法和上述文件流一致。

内容的提问来源于stack exchange，提问作者John