java - RxJava : How to retry on next?

Question

我知道:

• retryWhen(...) 允许我们在出错时重试

• 和 repeatWhen(...) 允许完成后重试

有没有这样的运算符:

    return Observable.just(isUpdating)
            .repeatWhenOnNext(isUpdating -> { 
                if(isUpdating) {
                    return Observable.timer(2, TimeUnit.SECONDS); // repeat after two seconds
                } else {
                    return Observable.just(isUpdating); // flow down to concatMap
                }
            })
            .concatMap(o -> doSomeWorkONLYWhenIsNotUpdating());

Answer 1

嗯...不，但也许这样可以:

return Observable
    .interval(0, 2, TimeUnit.SECONDS)
    .filter(dummy -> !isUpdating)
    .take(1)
    .flatM(dummy -> doSomeWorkONLYWhenIsNotUpdating());