angular - RxJs combineLatest 中的错误处理

Question

我正在使用 rxJs 在我的应用程序中检索和存储数据。我有一个场景，我正在尝试使用 combineLatest 订阅多个 observables。问题是，如果某些 observables 抛出错误，我将无法订阅，因为 subscribe 函数不会触发。我尝试将 .catch(err => err) 添加到每个可观察对象的末尾，但是 combineLatest.subscribe 不起作用。

Answer 1

只需使用 toPromise() 将 observable 转换为 promise 并使用 then / catch。

combineLatest([api1, api2]).toPromise()
.then(([api1Res, api2Res]) => {
  // do stuff
})
.catch(error => {
 // show error response
}