如何在resumeOnError (或类似)中使用RxJS5

Question

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

但是我可以在下面的文档中看到，在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示例：https://jsbin.com/qadozoveta/edit?html,js,console

Answer 2

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

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

onErrorResumeNext源代码