RxJavaでネットワークコールを再試行

Question

AndroidでrxJavaにネットワークエラーが発生した場合にネットワークコールを再試行する方法。

は、ここに私のrxJaveコードです：それは非常にうまく機能

RxTextView.textChanges(searchInput) 
      .debounce(500, TimeUnit.MILLISECONDS) 
      .map(CharSequence::toString) 
      .filter(s -> !s.isEmpty()) 
      .subscribeOn(AndroidSchedulers.mainThread()) 
      .observeOn(Schedulers.io()) 
      .switchMap(query -> getTypedPlaces(query)) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(results -> showResult(results)); 

が、接続がダウンしたとき、私は、ネットワーク要求を再試行する必要があります。

Answer 1

PublishSubjectを作成し、retryWhen(subject)を追加してください。

接続の変更をリッスンし、ネットワークが利用可能になったらsubject.onNext(null)と呼び出し、rxチェーンが停止していると再試行します。

.switchMap(query -> getTypedPlaces(query).retryWhen(subject)) 

他のノート...のTextViewのイベントがmainThread由来として

.subscribeOn(AndroidSchedulers.mainThread())は不要です。

.observeOn(Schedulers.io())が必要でない場合や、debounceでスケジューラを特別に設定することができます。