Fabio Rachid
01/11/2022, 10:13 PMzipWith
function from RxJava, but I’m getting an error
fun <T> applyObservableAsync(): SingleTransformer<T, T> {
return SingleTransformer { observable ->
observable
.subscribeOn(<http://Schedulers.io|Schedulers.io>())
.observeOn(AndroidSchedulers.mainThread())
.retryWhen{ errors -> errors.zipWith(Observable.range(1, REQUEST_RETRY_TIMES.toInt())
) { BiFunction { _: Flowable<Throwable>, i: Int -> i } }
.flatMap { Observable.timer(ProjectSettings.REQUEST_RETRY_DELAY, TimeUnit.SECONDS) }}
}
}