rxjsのエラーから回復するには？

Question

私は観察可能なシーケンスをどのように消費するか、そしてエラーから回復する方法を理解しようとしています。

私の例は少し工夫されていますが、実際の実装はここではあまりにも複雑すぎます。とにかく、ユーザーがUIをクリックしたときに値を返すsomeObservableがあります。これにより、API（GET/POST/etc）へのリクエストがトリガーされます。問題は、APIがエラーを返す場合、それ以降はpostDataは呼び出されないということです。

ここでは、問題を示す例を示します。私は、実行するためにRx.Observable.throwの代わりにRx.Observable.ofを使用できることを発見しました。しかし、それはsubscribe関数に値を出します。そして、私の実際のアプリケーションでは、postDataは、アプリケーションの複数の部分で再利用されるサービスであり、throwの代わりにofを使用したいと確信できません。

私の質問は、どのようにこれらのようなものを普通に扱うのですか？

let someObservable = Rx.Observable.timer(1, 1000); 

someObservable 
.switchMap(data => { 
    return postData(data); 
}) 
.catch(error => { 
    console.log("POST failed"); 
}) 
.subscribe(val => console.log("Success: " + val)); 

function postData(data) { 
    console.log("Will post " + data); 

    if (data !== 2) { 
    return Rx.Observable.of(true); 
    } 
    else { 
    return Rx.Observable.throw(new Error("400 Bad Request or something")); 
    } 
} 

http://jsbin.com/naroyeyive/3/edit?js,console

Answer 1

あなたが要求を再送信したい場合は、代わりにcatchのretryとretryWhenに見てみたいことがあります。

catchは、新しい "ソース"としてObservableを返します。 See this bin for an example.

retry(When)は、オペレータに渡す設定に基づいて、エラーが発生するたびに「再購読」します。ここでは例と詳細を見つけることができます：https://www.learnrxjs.io/operators/error_handling/retrywhen.html