Promises 和 switchMap

Question

以下代码有什么问题：

private async getData$(){
  const value = await anObservable$.pipe(
     switchMap(res => fetchData$(res)) // it works
   ).toPromise();
  console.log(value); // doesn't get here 
}

fetchData$ 有效，但线程未到达 console.log。控制台没有错误。

Answer 1

最终的承诺只会在 anObservable$ 完成后解决。如果它永远运行，承诺永远不会解决。如果您只对 anObservable$ 的一种发射感兴趣，您可以这样做：

private async getData$(){
  const value = await anObservable$.pipe(
     switchMap(res => fetchData$(res)),
     take(1)
   ).toPromise();
  console.log(value);
}

您可能无论如何都想要这样的东西，因为一旦可观察对象完成，承诺将随着其可观察对象的最后一次发射而解决。在此之前的任何排放量都被丢弃。

Promises 和 switchMap

Promises and switchMap

promise

rxjs