如何在 RxJS5 中 resumeOnError（或类似的）

Question

我想使用 RxJS 的 onErrorResumeNext 功能，即即使收到错误也继续接收事件（而不是终止）。

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

是否有使用此类功能的解决方法？谢谢！

Answer 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

Answer 2

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

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

onErrorResumeNext source code

如何在 RxJS5 中 resumeOnError（或类似的）

How to resumeOnError (or similar) in RxJS5

rxjs5