https://kotlinlang.org logo
Title
u

user

06/29/2022, 8:31 AM
RxJava - How to continue polling with observable interval if error occurs I have a simple network polling function with observable intervals private fun pollFromApi(): Observable { return Observable.interval(3L, TimeUnit.SECONDS, schedulerProvider.io()) .startWith(0L) .flatMap { api.getState().toObservable() } .map { // map response to MyState } .onErrorReturn { return@onErrorReturn MyState.Polling // if error occurred emit Polling State } .takeUntil {...