ES8立即调用异步函数表达式

Question

我没有看到这些构造使用很多，但我发现自己编写它们是为了在通常不会返回promise的函数中使用异步/等待

chan.consume(queue, (msg) => {
  this.pendingMsgs++; // executed immediately
  (async () => {
    await this.handleMessage(msg);
    this.pendingMsgs--;
    if (cancelled && this.pendingMsgs === 0) {
       await chan.close();
       await this.amqpConnectionPool.release(conn);
    } 
  })();
});

相对于

chan.consume(queue, async (msg) => { // external lib does not expect a return value from this callback
  this.pendingMsgs++;  // executed in promise context(?)
  await this.handleMessage(msg);
  this.pendingMsgs--;
    if (cancelled && this.pendingMsgs === 0) {
       await chan.close();
       await this.amqpConnectionPool.release(conn);
    }
});

或

chan.consume(queue, (msg) => {
  this.pendingMsgs++;  // no await - excess function decls & nesting
  this.handleMessage(msg).then(() => {
    this.pendingMsgs--;
    if (cancelled && this.pendingMsgs === 0) {
       chan.close().then(() => {
         this.amqpConnectionPool.release(conn);
       });
    }
  });
});

这是一件事吗？这里有我应该意识到的陷阱吗？在这种情况下使用async/wait的原因是什么？

Answer 1

(async () => {
        await func();
    })();

Answer 2

这是一件事吗？

对它不时出现，例如这里。它们被称为IIAFE:-）
如果你想把注意力集中在箭头上，你也可以称它们为IIAFS。

这里有我应该注意的陷阱吗？

无论何时调用promise返回函数而不将结果返回到其他地方，您都要自己对promise负责，这意味着您必须处理来自promise的错误。因此，模式大体上应该是这样的

(async () => {
    …
})().catch(err => {
    console.error(err);
});

如果您不想担心未处理的拒绝事件。

在这种情况下，async/await的使用有什么秘密？

与然后版本相比，不多。但是，您说“外部库不期望从这个回调中获得返回值”，这可能暗示了库与异步回调不兼容，所以要当心您在做什么。它还可能取决于从回调同步抛出的异常，所以这完全取决于库在这里期望什么（如果没有期望，将来是否会改变）。您不希望将来出现不兼容，以防库开始特别处理promise返回值。

但是，我仍然建议使用第二种模式直接将async函数作为回调传递，因为它具有更好的可读性。如果要避免向库返回promise，请创建一个包装回调的帮助函数：

function toVoid(fn) {
    return (...args) => void fn(...args);
}
function promiseToVoid(fn) {
    return (...args) => void fn(...args).catch(console.error);
}

您可以这样使用：

chan.consume(queue, toVoid(async (msg) => {
     … // use `await` freely
}));