Rx Kotlin повторить при выпуске - PullRequest
Новая
       15

Rx Kotlin повторить при выпуске

2 голосов
/ 20 июня 2019

Я пытаюсь использовать операцию .retryWhen(), чтобы повторить вызов API в случае сбоя 3 раза каждые 5 секунд. Может ли кто-нибудь помочь мне с этим делом, поскольку я не могу понять это в течение последних нескольких часов. 

.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))
                }
            )
    }

1 Ответ

0 голосов
/ 21 июня 2019

Я случай, когда кто-то ищет что-то подобное.Я пришел к решению, которое прекрасно работает для меня.

.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)
                }
            }
    }
}
...