doOnNext内にスローされたRxJavaの再試行

Question

AIM：何かが変更されたときに、ユーザーがリストをスクロールしなくても、アダプタを更新します。

doOnNextにエラーをスローして、もう一度やり直すことができます。しかし、これは動作していません。私は例外がスローされていることがわかりますが、retryWhenは何もしていないようです。

私はここで間違っていますか？

someObservable() 
    .observeOn(AndroidSchedulers.mainThread()) 
    .debounce(650, TimeUnit.MILLISECONDS) 
    .doOnNext(o -> { 
     if (isListScrolling()) { 
     throw new IllegalStateException(); 
     } 
    }) 
    .retryWhen(errors -> errors.flatMap(error -> Observable.timer(100, TimeUnit.MILLISECONDS))) 
    .subscribe(o -> refreshListNow()); 

UPDATE： someObservableはSubject（バス）である私は、上のUIイベントを観察しています。

retry()と思われるので、ここで私のコメントを見てください。おそらくBehaviorSubject - isnを使用していない限り、再試行でソースが自動的に最後の値を再発光しません。ここには適していない）。

Answer 1

あなたは値がemmitedであることは言及していません。だから私はこの例の文字列にします。 doOnNext内のスクロール状態をチェックするのは、retryWhenに戻すことができないため、遅すぎます。 flatMapを使用するだけで、代わりにエラーをスローすることができます。