使用 rxjs concat 时出现错误后如何继续调用 API?

Question

我正在使用concat按顺序调用多个API，但是当错误时，concat停止调用api，那么如何得到错误并继续调用下一个API，这是我的代码：

getData() {
concat(...this.data.map(asset =>
this.assetService.requestData({ assetId: asset._id })
))
.pipe(catchError(error => {
console.log(error);
// return of(null);
this.error = error;
return throwError(error);
}))
.subscribe();
}

Answer 1

对于每个可观察量，应单独进行错误捕获。您可以简单地返回一个空的可观察量：

import { EMPTY } from 'rxjs';
concat(...this.data.map(asset =>
this.assetService.requestData({assetId: asset._id})
.pipe(catchError(error => {
console.log(error);
this.error = error;
return EMPTY;
}))
))
.pipe(filter(data => !!data)) // add this line if you do not want to see nulls in result
.subscribe();

---

另一种选择是使用onErrorResumeNext函数：

import { onErrorResumeNext } from 'rxjs';
onErrorResumeNext(...this.data.map(asset => 
this.assetService.requestData({assetId: asset._id})
)
.subscribe();