相关疑难解决方法(0)

我在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而不是捕获,但我无法使这项工作.

Rx.Observable.if如果条件observable解析为true或false,我想用它来运行两个observable中的一个.

我想要实现的将是这样的:

Rx.Observable.if(conditionalObservable.map(x => x.length > 0), firstObservable, secondObservable).subscribe()

如果conditionalObservable发送一个next然后以true值完成,则firstObservable应该运行,否则,secondObservable应该运行.

现在显然这不起作用,因为Rx.Observable.if期望一个函数有条件,而不是一个可观察的.如何在RXJS中实现完全相同的功能？

注意:这个问题几乎相同,但我认为它不够简洁,因为1)你必须有两个pausable语句和2)除非你附加一个take(1)条件的observables,你不能保证条件不会发出更多下一个活动.IMO这是一种解决方法,更容易出现人为错误.