使用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

错误捕获应该针对每个 observable 单独发生。你可以简单地返回一个空的 observable：

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();