rxjs5 - RxJS5 で ResumeOnError (または類似) する方法

Question

onErrorResumeNextRxJS の機能、つまり、エラーが発生しても (終了せずに) イベントを受信し続けたいと考えています。

しかし、次のドキュメントで 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