执行具有可观察值和发出值的任务
private val performTask = io.reactivex.Observable.create<Boolean>({ emitter ->
// do somethinf
emitter.onNext(true)
emitter.onComplete()
})
这也是重试的另一个可观察到的情况。我想重试 2 次,但前提是执行任务成功。
fun <T> io.reactivex.Observable<T>.retryAuth(): Observable<T> {
return this.retry ({ count, error ->
if (count == 2 && error is ApolloException) {
// do something with performTask and return the value
} else false
})
只需要说明如何实现这一目标
您可以使用retryWhen
:
this.retryWhen({ errors ->
val counter = AtomicInteger()
.flatMap({ error ->
if (counter.incrementAndGet() <= 2 && error is ApolloException) {
return performTask
.flatMap({ result ->
if (result) {
return Observable.just(true)
}
return Observable.error(error)
})
}
return Observable.error(error)
})
})