combine_retry

combine_retry.swift

import Combine
import Foundation

enum CustomError: Error {
    case retryError
    case otherError
}

var count = 0

let publisher = Deferred {
    Future<String, CustomError> { callback in
        DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
            switch count {
            case 2:
                callback(.failure(.otherError))
            case let n where n < 3:
                callback(.failure(.retryError))
            default:
                callback(.success("**(\(count))**"))
            }
            count += 1
        }
    }
}

let cancellable = publisher
    .print("DEBUG")
    .retry(5)
    .sink(receiveCompletion: {
        print("receiveCompletion \($0)")
    }, receiveValue: {
        print("receiveValue \($0)")
    })