Observable+RetryDelay.swift

extension Observable {

    /// maxAttemptまでdelay間隔をあけてリトライする
    ///
    /// - Parameters:
    ///   - maxAttempt: 最大リトライ回数
    ///   - delay: 間隔
    /// - Returns: リトライしたObservable
    func retry(_ maxAttempt: Int, delay: RxTimeInterval) -> Observable<Element> {
        return retryWhen { (err: Observable<Error>) -> Observable<Int> in
            return err.enumerated().flatMap { (count, err) -> Observable<Int> in
                guard count < maxAttempt - 1 else {
                    return Observable<Int>.error(err)
                }
                let serialQ = SerialDispatchQueueScheduler(qos: .background)
                return Observable<Int>.timer(delay, scheduler: serialQ)
            }
        }
    }
}