2

我想使用onErrorResumeNextRxJS 的特性,即即使收到错误也继续接收事件(而不是终止)。

但我可以在以下文档中看到 RxJS5 中没有对应关系:https ://github.com/ReactiveX/RxJS/blob/master/MIGRATION.md 。

是否有使用此类功能的解决方法?谢谢!

4

2 回答 2

1

我也一直在找那个接线员!我想出了一个满足我需求的解决方案,希望对您有所帮助。这很可能不是最好的解决方案,但我希望它可以提供帮助,直到其他人在这里找到更好的解决方案,或者直到在 5.0 中重新添加该运算符(希望如此!):)

var Observable = Rx.Observable;

var source1 = Observable.create(function(observer){
    observer.error();
});
var source2 = Observable.create(function(observer){
    observer.next('Continuing on');
    observer.complete();
});


var stream = source1.catch(function(data){
  return source2;
});



stream.subscribe(function(data){
  console.log(data);
});

JS Bin 示例:https ://jsbin.com/qadozoveta/edit?html,js,console

于 2016-06-14T22:20:19.453 回答
0

您仍然可以在 rxjs5 中使用以下内容。

 Observable.onErrorResumeNext(observable1$, observable2$, observable3$...)
           .subscribe(() => { ... })

onErrorResumeNext 源代码

于 2017-06-26T21:42:03.297 回答