如何用回调函数兑现Promise？及异步函数等待EventEmitter事件方案

我来分别解答你的两个问题：

问题1：如何使用回调函数来兑现一个Promise？ #

核心思路就是把回调风格的异步逻辑包装进Promise实例，用resolve()对应回调的成功结果，reject()对应回调的错误情况。举个实际的例子，比如把Node.js里基于回调的文件读取转成Promise：

const fs = require('fs');

// 封装回调式API为Promise
function readFilePromise(filePath) {
  return new Promise((resolve, reject) => {
    // 这里放入原回调逻辑
    fs.readFile(filePath, (error, content) => {
      if (error) {
        // 回调报错时，用reject抛出错误
        reject(error);
      } else {
        // 回调成功时，用resolve返回结果
        resolve(content);
      }
    });
  });
}

// 调用示例（用async/await）
async function run() {
  try {
    const data = await readFilePromise('./demo.txt');
    console.log('文件内容:', data.toString());
  } catch (err) {
    console.error('读取失败:', err);
  }
}

run();

说白了，Promise的执行器函数就是用来衔接回调和Promise世界的桥梁——你把原来的回调逻辑放进去，在回调的成功分支调用resolve()传递结果，失败分支调用reject()传递错误，就完成了用回调兑现Promise的操作。

问题2：在异步函数中等待EventEmitter事件触发 #

你的场景是要等maildev的new事件拿到邮件URL后再继续执行，这里的关键是把EventEmitter的事件转换成Promise，因为await只能等待Promise对象。

注意不要用maildev.on()，因为它会持续监听所有new事件，我们只需要等待第一次触发的新邮件，所以用maildev.once()更合适（避免内存泄漏，也不会多次resolve Promise）。修改后的代码如下：

(async () => { 
  await send_semail(); 
  // 将事件监听包装为Promise
  const url = await new Promise((resolve) => {
    // 监听一次'new'事件，触发后resolve邮件的url
    maildev.once('new', (mail) => {
      resolve(mail.url);
    });
  });
  await visit(url); 
})();

这样异步函数会在await处暂停，直到maildev触发new事件，回调里拿到mail.url并resolve Promise，之后就会继续执行visit(url)。

如果怕一直收不到邮件导致程序挂起，还可以给Promise加个超时逻辑：

(async () => { 
  await send_semail(); 
  const url = await new Promise((resolve, reject) => {
    // 设置30秒超时
    const timeoutTimer = setTimeout(() => {
      reject(new Error('等待新邮件超时，请检查服务'));
    }, 30000);

    maildev.once('new', (mail) => {
      clearTimeout(timeoutTimer); // 收到邮件后清除超时定时器
      resolve(mail.url);
    });
  });
  await visit(url); 
})();

这样就更健壮啦。

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