Rx Kotlin retryWhen问题

Question

我正在尝试使用.retryWhen()操作在失败的情况下每5秒重试一个api调用3次。有人能帮我处理一下这个案子吗?因为我在过去几个小时里弄不清楚。

.retryWhen { errors ->
                errors
                    .zipWith(Observable.range(1, 3), { _: Throwable, i: Int -> i })
                    .flatMap { retryCount: Int ->
                        Observable.timer(
                            5.0.pow(retryCount.toDouble()).toLong(),
                            TimeUnit.SECONDS
                        )
                    }
            }

我得到了

None of the following functions can be called with the arguments supplied:
@CheckReturnValue @SchedulerSupport public final fun <U : Any!, R : Any!> zipWith(p0: ((Observer<in Int!>) -> Unit)!, p1: ((Throwable, Int) -> ???)!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <U : Any!, R : Any!> zipWith(p0: ObservableSource<out Int!>!, p1: BiFunction<in Throwable!, in Int!, out (???..???)>!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <U : Any!, R : Any!> zipWith(p0: (Mutable)Iterable<(???..???)>!, p1: BiFunction<in Throwable!, in (???..???), out (???..???)>!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <U : Any!, R : Any!> zipWith(p0: (Mutable)Iterable<Int!>!, p1: ((Throwable, Int) -> ???)!): Observable<(???..???)>! defined in io.reactivex.Observable

我还粘贴了我试图执行的全部代码：

private fun getOrderDetails(uuid: String) {
        apiClient.getOrderDetailsUsingUUID(uuid)
            .retryWhen { errors ->
                errors
                    .zipWith(Observable.range(1, 3), { _: Throwable, i: Int -> i })
                    .flatMap { retryCount: Int ->
                        Observable.timer(
                            5.0.pow(retryCount.toDouble()).toLong(),
                            TimeUnit.SECONDS
                        )
                    }
            }
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({ webOrderRequest ->
                _currentOrder.value = OrderState.OrderDetails(webOrderRequest.order!!)
                orderStatus(uuid, webOrderRequest.order)
            },
                { error ->
                    _currentOrder.value = OrderState.Error(getErrorMessage(error))
                    Log.e(TAG, getErrorMessage(error))
                }
            )
    }

Answer 1

我想有人在找类似的东西。我想出了一个对我有用的解决方案。

.retryWhen { errors ->
                errors.zipWith(Observable.range(1, 3), BiFunction { throwable: Throwable, count: Int -> Pair(throwable, count) })
                    .flatMap { count: Pair<Throwable, Int> ->
                        if (count.second < 3) {
                            Observable.timer(5, TimeUnit.SECONDS)
                        } else {
                           Observable.error(count.first)
                        }
                    }
            }

它的扩展：。

import io.reactivex.Observable
import io.reactivex.functions.BiFunction
import java.util.concurrent.TimeUnit

fun <T> Observable<T>.retryWhenError(retryCount: Int, delayInSeconds: Long): Observable<T> {
    return retryWhen { errors ->
        errors.zipWith(
            Observable.range(1, retryCount), BiFunction { throwable: Throwable, count: Int -> Pair(throwable, count) })
            .flatMap { count: Pair<Throwable, Int> ->
                if (count.second < retryCount) {
                    Observable.timer(delayInSeconds, TimeUnit.SECONDS)
                } else {
                    Observable.error(count.first)
                }
            }
    }
}