rx-java - Rxjava，在onComplete或onError之后如何重复

Question

我有一个代码块可能是这样的。

fun main() {
    foo()
            .flatMap {
                bar()
            }
            .subscribe({}, {
                main()
            },{
                main()
            })
}

fun foo(): Observable<Int> {
    // has some real business which take times here
    return Observable.just(1)
}

fun bar(): Observable<Int> {
    // has some real business which take times here
    return Observable.just(2)
}

这将在 onComplete 或 onError 之后重复。

但是我觉得上面的风格不好！RxJava 本身有什么好的方法吗？

标签： rx-java

Answer 1

尝试申请retry和repeat：

foo()
.flatMap {
     bar()
}
.retry()           // <------------------------------------------
.repeat()
.subscribe({}, {
    // never fails
},{
    // never ends
})