带有 Observable 或 Promise 的 Typescript async/await

Question

我可以像这样使用async 和await 吗？我在这里杀死async/await 吗？ 下面的代码可以正常工作，我知道async/await 仅适用于Promise<T>。我的getItem 是Observable。谢谢。

roleService.getItem({ page: p.pageIndex + 1, pageSize: p.pageSize })
.takeUntil(this.unsubscribe$)
.map((res: ResponseDto) => <DtoModel>res.contentBody)
.do(async (dto: DtoModel) => await this.subject.next(dto.content)) // working wihtout error
.subscribe(async (dto: DtoModel) => await (this.pager = dto.pager), //working without error
          (error: any) => Observable.throw(error));

Answer 1

您可以按照您的方式使用async 函数，但它在您的示例中不起作用。你要明白async函数返回一个promise：

const fn = async function() {};
fn() instanceof Promise

因此，如果您在可观察链中使用它，您将收到一个承诺：

interval(500)
  .first()
  .map(async (v) => {
    return v;
  })
  .subscribe((v) => {
    console.log(v instanceof Promise); // logs `true`
  });

您构建示例的方式不会对 observables 链产生任何影响，因为 do 运算符的输出被忽略，并且 subscribe 回调的输出没有监听器。所以基本上没有理由在那里使用async。

如果您想等到async 函数解析并获取该函数的结果，请使用mergeMap 运算符：

interval(500)
  .first()
  .map(async (v) => {
    return v;
  })
  .mergeMap((p) => {
    return p;
  })
  .subscribe((v) => {
    console.log(v);
  });