角2 RxJS Observable：429のステータスを除いて再試行

Question

Observable（HTTPリクエストから）を作成して失敗時に再試行しました。しかし、サーバが429 Too many requestsエラーで応答した場合、はを再試行したいと思います。

現在の実装では、何があっても1秒間隔で2回リトライします。

return this.http.get(url,options) 
    .retryWhen(errors => { 
     return errors.delay(1000).take(2); 
    }) 
    .catch((res)=>this.handleError(res)); 

errorsは、観察可能である。エラーの原因となった基になるResponseオブジェクトを取得するにはどうすればよいですか？それを私は、サーバーのステータスコードにアクセスし、それが429ではない場合のみ、再試行することができます。

return this.http.get(url,options) 
    .retryWhen(errors => { 
     if($code == 429) throw errors; 
     else return errors.delay(1000).take(2); 
    }) 
.catch((res)=>this.handleError(res)); 

にはどうすればretryWhen内ステータスコードを取得できますか？

Live demo on Plunker

Angular 2 rc.6、RxJS 5 Beta 11、Typescript 2.0.2

Answer 1

あなたはretryWhenに渡された観測可能errorsに429のエラーの処理を構成することができます。サーバーから受信したエラーの場合は、errors観測値から出力されるエラーにはstatusプロパティが含まれます。

あなたは429のエラーが発生したときに再試行し、代わりにあなたがこのような何かを行うことができ、エラーをスローしたいしたくない場合は、次の

return this.http.get(url,options) 
    .retryWhen((errors) => { 
     return errors 
      .mergeMap((error) => (error.status === 429) ? Observable.throw(error) : Observable.of(error)) 
      .delay(1000) 
      .take(2); 
    }) 
    .catch((res) => this.handleError(res)); 

場合は、代わりに、あなたは発光せずに完了することが観察できるHTTPを望んでいましたエラーまたはレスポンスのいずれかを指定すると、429個のエラーをフィルタリングできます。