<RxJava - How to continue polling with observable ...

# stackoverflow

[user]

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 {...