RXJS TAP操作员支持异步函数＆＃xff1f;

Question

我的示例代码是

    this.urls$.pipe(
      map(async (val) => {
        return await http.get(url);
      }),
      tap(async (val) => {
        const res = await val.res;
        console.log(res);
        return ture;
      })
    ).subscribe();

，但我收到了一条ESLINT消息。

预期返回空隙。

在函数辩论中返回的承诺，可以

Answer 1

您可以将承诺转换为可观察的，并使用switchmap（或simelar）运算符，而不是等待地图中的承诺。

this.urls$.pipe(
      switchMap((val) => from(http.get(url))),
      tap((val) => console.log(val.res)),
    ).subscribe();