angular – 处理RxJs flatMap流中的错误并继续处理

发布时间：2020-12-17 17:32:28 所属栏目：安全来源：网络整理

导读：我在Angular 2应用程序中使用 RxJs来并行地从API获取多个页面的数据,并保存任何失败的请求以供将来重试. 为此,我想捕获flatMap-ing http get请求(下面的代码)生成的错误,并继续进行进一步的流处理.如果出现错误,我当前的解决方案会导致流停止. Rx.Observable

我在Angular 2应用程序中使用 RxJs来并行地从API获取多个页面的数据,并保存任何失败的请求以供将来重试.

为此,我想捕获flatMap-ing http get请求(下面的代码)生成的错误,并继续进行进一步的流处理.如果出现错误,我当前的解决方案会导致流停止.

Rx.Observable.range(1,5)
   .flatMap(pageNo => {
              params.set('page',''+pageNo);
              return this.http.get(this.API_GET,params)
                        .catch( (err) => {
                                  //save request
                                  return Rx.Observable.throw(new Error('http failed')); 
                          });
    })
    .map((res) => res.json());

让我们说在上面的例子中,第2页和第3页的HTTP请求失败.我想为这两个请求处理错误(保存失败的请求以后重试),并让其他请求继续并映射到json().

我尝试使用.onErrorResumeNext而不是catch,但我无法使其工作.

解决方法

在catch中,不要返回Observable.throw,然后它应该根据需要继续流.

如果要将信息传播到外部流,可以使用返回Observable.of(“Error：Foo.Bar”);例如.

或者在catch中记录错误并返回一个Observable.empty()以使外部流基本上忽略该错误.

换句话说,只是链接这个：

.catch(error => Rx.Observable.of(error));

const stream$= Rx.Observable.range(1,5)
    .flatMap(num => {
      return simulateRest(num)
             .catch(error => {
                 console.error(error);
                 return Rx.Observable.empty();
             });
      });
             
stream$.subscribe(console.log);

// mocking-fn for simulating an error
function simulateRest(num) {
    if (num === 2) {
        return Rx.Observable.throw("Error for request: " + num);
    }
  
    return Rx.Observable.of("Result: " + num);
}

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!