如何从事件发射器调用的同步函数中返回同步函数的值？

Question

我有同步工作逻辑，我想把它转换成异步事件驱动代码。

如何让 async foo 在事件链的末尾返回回调的承诺值（ done() || fail() ）？

就像让这个过于简单的例子起作用

async function foo(param){
  eventEmitter.emit('first-event', param);
}

eventEmitter.on('first-event', /*Do something*/);
.
.
.
eventEmitter.on('last-event', (payload) => {
  try{
   /*If no error*/
   eventEmitter.emit('done', payload);
  }catch{
   /*If error*/
   eventEmitter.emit('fail', error);
  }
});

function done(payload){
  return ({payload:payload});
}

function fail(error){
  return ({fail:error});
}

eventEmitter.on('done', payload => done(payload) );

eventEmitter.on('error', error => fail(error) );

如果有人知道它的相关信息，感谢您分享它和您的时间，如有任何错误，我们深表歉意。

Answer 1

经过大量阅读以下的cmets和链接：

@Bergi 
@TheMaster
@Thomas

我认为我找到了最好的解决方案我希望我没有错，如果我是的话，我希望不要过分要求那些回应的人这样做是为了解决问题而不是仅仅指点出一个错误或不喜欢的东西。

“请给我看代码！” ;)

这是拆分字符串的最愚蠢方法的示例 使用 eventEmitter、async await 和这种方法并且有效！

let event = new(require('events').EventEmitter);

async function split(string) {

  let holder = {};
  let promise = async() => {
    return await (holder.payload || holder.error) ? holder : null;
  }

  event.on('done', data => done(data));

  function done(data) {
    try {
      console.log('Done emitted');
      console.log(`Param: ${data}`);
      holder.payload = data;
    } catch(error) {
      console.log(error);
    }
  }

  event.on('error', error => fail(error));

  function fail(error) {
    try {
      console.log('Fail emitted');
      console.log(`Param: ${error}`);
      holder.error = error;
    } catch(error) {
      console.log(error);
    }
  }

  event.on('split', async(string) => {
    try {
      console.log('Split emitted');
      console.log(`Param : ${string}`);
      const data = string.split(' ');
      event.emit('done', data);
    } catch(error) {
      console.log(error);
      event.emit('error', error);
    }
  });

  try {
    event.emit('split', string);
    return({ payload: await promise().then(data => { return data.payload }) });
  } catch(error) {
    console.log(error);
  }

}

console.clear()
console.log(
  split('Hello world').then(data => {
    console.log('Split done!');
    console.log(data);
  })
);

所以此时 var 'holder' 和 function 'promise' 位于函数“split”的范围内，所有控制台输出为：

Split emitted
Param : Hello world
Done emitted
Param: Hello,world
Promise { <pending> }
Split done!
{ payload: [ 'Hello', 'world' ] }

重点是说明可以有 n 个异步事件、回调和承诺 并且能够在经过 n 个阶段或事件的过程后返回一个值

感谢您的时间，以及任何其他 cmets，对于任何错误，我们深表歉意。

Answer 2

如果你必须这样做，promise 构造函数将起作用：

let p = {};
async function foo(param) {
  eventEmitter.emit('first-event', param);
  return await new Promise((res, rej) => (p.res = res) && (p.rej = rej));
}
//...
eventEmitter.on('done', payload => done(payload) && p.res());

eventEmitter.on('error', error => fail(error) && p.rej());