时间戳

首页 > 解决方案 > 使用rxjs concat时出现错误后如何继续调用API？

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

问题描述

我正在使用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();

  }

标签： angularrxjs6

解决方案

错误捕获应该针对每个 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();

推荐阅读