Publishers.MapError

제네릭 구조체 | 상위에 흐르는 Publisher의 어떠한 실패를 새로운 에러로 변환하는 Publisher

이니셜라이저는 두 개의 인자를 받는다.

• upstream : 상위에 흐르는 Publisher

• transform : 상위에 흐르는 Publisher의 실패를 새로운 에러로 변환하는 클로저

upstream Publisher의 에러 타입은 Error다.

에러를 변환하기 위해 사용한다. 에러를 처리하는 것이 아니므로 상위에 흐르는 Publisher가 에러를 내고 별도의 에러 처리 작업이 없다면 에러를 내며 종료하게 된다.

mapError 오퍼레이터와 관련이 있다.

// Publishers.MapError Publisher
Publishers.MapError(upstream: Fail<Void, NSError>(error: error), { $0 as Error })
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine MapError Error")
    case .finished:
      print("Combine MapError Finish")
    }
  }, receiveValue: {
    print("Combine MapError")
  })
  .store(in: &cancellables)

// mapError Operator
Fail(error: error)
  .mapError { $0 as Error }
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine MapError Error")
    case .finished:
      print("Combine MapError Finish")
    }
  }, receiveValue: {
    print("Combine MapError")
  })
  .store(in: &cancellables)

// Combine MapError Error

두 코드 모두 상위 Publisher로 NSError 객체를 받는 Fail Publisher를 사용하였다.

$0 as Error를 통해 NSError 타입이 Error 타입으로 매핑된다.

상위에 흐르는 Publisher가 에러를 내므로 결과적으로 에러를 내며 종료한다.

RxSwift

내부적으로 에러의 타입으로 Error를 노출하므로 mapError와 같이 에러의 타입을 변환하는 오퍼레이터를 제공하지 않는다.

Observable<Void>.error(error)
  .subscribe(onNext: {
    print("RxSwift MapError")
  }, onError: { _ in
    print("RxSwift MapError Error")
  }, onCompleted: {
    print("RxSwift MapError Finish")
  })
  .disposed(by: disposeBag)

// RxSwift MapError Error

ReactiveSwift

mapError 오퍼레이터를 사용하여 구현할 수 있다.

SignalProducer<Void, NSError>(error: error)
  .mapError { $0 as Error }
  .start { event in
    switch event {
    case .value:
      print("ReactiveSwift MapError")
    case .failed:
      print("ReactiveSwift MapError Error")
    case .completed:
      print("ReactiveSwift MapError Finish")
    default:
      break
    }
  }