如何让异步函数仅在特定节点返回，避免默认返回void

原代码的核心问题 #

1. fun函数未声明为async却使用await，直接语法报错
2. 回调版fs.readdir不返回Promise，无法用await等待结果
3. forEach不支持异步等待，内部的await完全无效，会导致流计数逻辑失效
4. 事件监听回调里的await和return list无意义——回调的返回值不会关联到主函数，也无法等待事件触发的异步逻辑
5. hostlist.forEach里的async纯属多余，push是同步操作

修正后的实现方案 #

核心思路是把每个文件的流操作封装为Promise，用Promise.all等待所有流处理完成后，再返回收集到的结果：

const fs = require('fs').promises; // 使用Promise版本的fs模块
const path = require('path');
// 替换成你实际使用的JSON解析流库
const json = require('your-json-parse-stream-lib');

const fun = async () => {
  const list = [];
  // 用await直接获取文件列表，无需回调嵌套
  const files = await fs.readdir(JSON_DIR);

  // 把每个文件的流处理转换成Promise
  const streamTasks = files.map(filename => {
    return new Promise((resolve) => {
      const readStream = fs.createReadStream(path.join('directory', filename));
      const parseStream = json.createParseStream();

      // 直接展开数组批量push，比forEach更高效
      parseStream.on('data', (hostlist) => {
        list.push(...hostlist);
      });

      // 当前文件的流处理完成时，标记任务完成
      parseStream.on('end', resolve);
      // 处理流错误，避免Promise永久pending
      readStream.on('error', resolve);
      parseStream.on('error', resolve);

      readStream.pipe(parseStream);
    });
  });

  // 等待所有文件的流处理完成
  await Promise.all(streamTasks);

  // 所有流都处理完毕后，返回收集到的结果
  return list;
};

关键说明 #

• 用fs.promises.readdir替代回调版本，彻底消除回调嵌套，配合await同步获取文件列表
• 每个文件的流生命周期封装为一个Promise，确保单个文件处理完成后才标记任务结束
• Promise.all会等待所有流任务完成，保证list收集到所有数据后才返回
• 增加流错误监听，避免单个流出错导致整个函数挂起

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