Rxjs Observable IntervalとAngular2 HTTP：応答待ち

Question

一定の間隔（5秒ごと）でログをポーリングするサービスを作成しようとしています。 http GETコールを行う必要がありますが、遅い接続と大きなログでは、switchMapは以前の保留中の要求をキャンセルします。したがって、要求がキャンセルされているのでログを取得することはありません。

getLog(url:string):Observable<string> { 
    return Observable 
     .timer(0, 5000) 
     .switchMap(() => this.get(url)) 
     .retryWhen(error => error.delay(5000)) 
     .map((res:Response) => res.text()) 
     .catch(e => { 
      console.warn(e.toString()); 
      return Observable.from(""); 
     }); 
} 

とthis.get(url)単にget(url) {return this.http.get(url)}です。

私はタイマーの機能を維持しようとしていますが、以前のコールが解決されるまで別のhttpコールをトリガーしないようにしています。

Answer 1

switchMap()の代わりにconcatMap()を使用してください。

あなたはswitchMap()オペレータが以前のリクエストをキャンセルしたと言いました。 flatMap()（またはmergeMap()）演算子はObservableをもう1つ作成し、すぐにそのすべてにサブスクライブします。

一方、concatMap()オペレータは、以前のObservableが完了するまで待ってから、次のObservableにサブスクライブします。だからあなたのタイマーが要求が完了したよりも速く発光している場合でも、あなたは常に同じ順序ですべての応答を受け取ります。