RxSwift retry interval with condition

retryInterval.swift

extension ObservableType {
    public func retryInterval(_ intervals: [RxTimeInterval], when f: @escaping (Error) -> Bool) -> Observable<Self.Element> {
        return retryWhen { error -> Observable<Int> in
            error.flatMap { e -> Observable<Void> in
                guard f(e) else { return .error(e) }
                return .just(())
            }
            .zip(with: Observable<RxTimeInterval>.from(intervals)) { $1 }
            .flatMap { Observable<Int>.timer($0, scheduler: Schedulers.background) }
        }
    }
}

관련 포스팅
Rx.retryInterval

Self.E is marked deprecated, Use self.Element instead. (since RxSwift 5.0.1, authored by freak4pc on 22 Apr 2019)

updated for RxSwift 5.0.1 (Thanks.)