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