java - 如何使用 retryWhen() Rxandroid

Question

我使用 RXJava 调用一个昂贵的递归函数。大多数时候它运行得非常快，但有时它会生成太长的 take 方式

如果线程仍在运行，有没有办法在 5 秒后使用 retryWhen()？

 observable = getObservable(); ///Runs a recursive function
 mObserver = getSudokuPuzzleObserver();

 observable.subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .retryWhen() // How to use retryWhen onNext() isn't called in 5 seconds
            .subscribe(mSudokuPuzzleObserver);

Answer 1

我不知道它是否适合你的解决方案，但我想到了类似的东西

    Observable observable = getObservable();
    observable.timeout(5, TimeUnit.SECONDS)
            .retry(e -> e instanceof TimeoutException)
            .subscribe(mSudokuPuzzleObserver);

timeout 如果 observable 在 5 秒内没有发出任何东西，将抛出异常，如果错误是由超时引起的，onError 它将重试完全相同的 observable。