Node.js中如何结合stream/promises与async函数修复ESLint报错

你遇到的no-async-promise-executor报错是因为ESLint禁止为Promise构造函数的执行器添加async标识，async执行器抛出的错误无法被外层Promise捕获，会触发未处理的Promise拒绝风险，属于典型的代码坏味道。

Node 15以上版本可以直接使用stream/promises内置的pipeline方法实现流的异步等待，重构后的代码如下：

const { pipeline } = require('stream/promises');
const fs = require('fs');

async function doSomething(url) {
  const res = await fetch(url);
  // 增加响应校验，避免下载到错误响应内容
  if (!res.ok) {
    throw new Error(`下载请求失败，状态码：${res.status}`);
  }

  const fileWriteStream = fs.createWriteStream(someFile, {
    autoClose: true,
    flags: 'w'
  });

  // pipeline会自动处理流的拼接、错误捕获、资源释放
  await pipeline(res.body, fileWriteStream);

  // 下载完成后执行后续操作
  await doWhatever();

  return 'DONE';
}

• 完全移除了手动封装的Promise，所有异步逻辑通过async/await实现，符合ESLint规范
• 相比原生pipe方法，pipeline会自动销毁所有流资源避免内存泄漏，任意环节报错都会直接抛出到外层，无需手动监听error事件
• 错误处理更统一：调用doSomething时只需外层包裹try/catch即可捕获所有场景的异常（请求失败、写入失败、后续操作失败等）

如果需要兼容Node 15以下版本，可以使用util.promisify转换回调版pipeline：

const { pipeline } = require('stream');
const { promisify } = require('util');
const pipelineAsync = promisify(pipeline);

// 后续使用和上面一致，调用await pipelineAsync(...)即可

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