RxJava retry interval with condition

retryInterval.kt

fun <T> Observable<T>.retryInterval(intervals: List<Long>, filter: (Throwable) -> Boolean): Observable<T> {
    return this.retryWhen { throwable ->
        throwable
            .flatMap { e ->
                if (!filter(e)) return@flatMap Observable.error<Throwable>(e)
                return@flatMap Observable.just(e)
            }
            .zipWith(Observable.fromIterable(intervals)) { _, i -> i }
            .flatMap { Observable.timer(it, TimeUnit.MILLISECONDS, Schedulers.newThread()) }
    }
}

관련 포스팅
Rx.retryInterval