[iOS - SwiftUI] Combine의 Publisher 연산자 (Just, Sequence, Future, Fail, Empty, Deferred, Record)

목차) Combine - 목차 링크

Just

• 에러 타입은 항상 Never인 가장 단순한 형태의 Publisher

Just(1)
  .sink { print("Just: \($0)") }
// Just: 1

Just((1,2,3))
  .sink { print("Just: \($0)") }
// Just: (1, 2, 3)

Just([1,2,3])
  .sink { print("Just: \($0)") }
// Just: [1, 2, 3]

Sequence

• 주어진 Sequence를 방출하는 Publisher

Publishers.Sequence<[Int], Never>(sequence: [1,2,3])
  .sink(
    receiveCompletion: { print("receiveCompletion: \($0)") },
    receiveValue: { print("receiveValue: \($0)") }
  )

/*
 receiveValue: 1
 receiveValue: 2
 receiveValue: 3
 receiveCompletion: finished
*/

• Sequence의 extension에 .publisher 프로퍼티가 있기 때문에 매우 간편하게 사용도 가능

[1,2,3].publisher // <-
  .sink(
    receiveCompletion: { print("receiveCompletion: \($0)") },
    receiveValue: { print("receiveValue: \($0)") }
  )

Future

• Result 타입과 같이 성공 or 실패 두 가지 타입을 갖는 Publisher

final class Future<Output, Failure> where Failure : Error

ex1)

• Future의 클로저의 promise 타입은 단순히 Result 타입을 가지고 있는 closure

Future<Int, Never> { promise in
  promise(.success(5))
}
.sink { print($0) }

// 5
// promise 타입은 (Result<Int, Never>) -> Void

ex2)

• Future을 사용하지 않은 코드

struct ImageProcessorService {
  func run(
    _ image: UIImage,
    completion: (Result<UIImage, Error>) -> Void
  ) -> Void {
    print("some function")
  }
}

• Future를 사용한 코드
  • promise 타입은 단순히 Result타입을 인수로 가지고 있는 클로저라서 위에서 정의한 completion이 있는 코드도 바로 사용이 가능

extension ImageProcessorService {
  func run(_ image: UIImage) -> Future<UIImage, Error> {
    Future { promise in
      self.run(image, completion: promise)
    }
  }
}

Fail

• fail을 바로 스트림으로 보내는 Publisher
  • 첫번째 인수는 에러를 방출할때 같이 방출할 값

public struct Fail<Output, Failure> : Publisher where Failure : Error

ex)

["50", nil, "70"]
  .publisher
  .flatMap { value -> AnyPublisher<String, MyError> in
    guard let value = value else {
      return Fail<String, MyError>(error: .isNil).eraseToAnyPublisher()
    }
    return Just(value).setFailureType(to: MyError.self).eraseToAnyPublisher()
  }
  .sink(
    receiveCompletion: { print("receiveCompletion: \($0)") },
    receiveValue: { print("receiveValue: \($0)") }
  )
/*
 receiveValue: 50
 receiveCompletion: failure(__lldb_expr_67.MyError.isNil)
*/

Empty

• 값을 방출하지 않고 즉시 완료되는 Publisher

Empty<String, Never>()
  .sink(
    receiveCompletion: { print("receiveCompletion: \($0)") },
    receiveValue: { print("receiveValue: \($0)") }
  )

// receiveCompletion: finished

Deferred

• 구독이 일어나기 전까지 대기하고 있다가, 구독이 일어났을 때 Deferred 클로저 부분이 실행되는 Publisher

Deferred { Just(1) }
  .sink(
    receiveCompletion: { print("receiveCompletion: \($0)") },
    receiveValue: { print("receiveValue: \($0)") }
  )
/*
 receiveValue: 1
 receiveCompletion: finished
*/

* 참고

https://developer.apple.com/documentation/combine/deferred

https://developer.apple.com/documentation/combine/future