【Swift/Combine】catchメソッドの使い方！エラーを補足する方法

func `catch`<P>(_ handler: @escaping (Self.Failure) -> P) -> Publishers.Catch<Self, P> where P : Publisher, Self.Output == P.Output

let publisher = PassthroughSubject<Int, MyError>()

let subscription = publisher
    .catch { error in
        // エラーが発生するとここが呼ばれる
        // クロージャーの引数から対象errorを参照できる
        // 後続のストリームに流すpublisherを返す
        Just(0)
    }
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("完了")
        case .failure(let error):
            print("Error:", error)
        }
    }, receiveValue: { value in
        print("Value:", value)
    })

// パブリッシャーから値を送信
publisher.send(10)
publisher.send(completion: .failure(NSError(domain: "", code: 0, userInfo: nil)))

Value: 10
Value: 0
完了

let publisher = PassthroughSubject<Int, MyError>()

enum MyError: Error {
    case someError1
    case someError2
}

let subscription = publisher
    .catch { error -> AnyPublisher<Int, MyError> in
        switch error {
        case .someError1:
            // エラーをそのまま返す
            return Fail(error: error).eraseToAnyPublisher()
        case .someError2:
            // 代替の値を返す
            return Just(0).setFailureType(to: MyError.self).eraseToAnyPublisher()
        }
    }
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("完了")
        case .failure(let error):
            print("Error:", error)
        }
    }, receiveValue: { value in
        print("Value:", value)
    })

// パブリッシャーから値を送信
publisher.send(10)
publisher.send(completion: .failure(.someError1))