[Combine] Publisher

발행🏭

Publisher

이전 글에서 publisher는 값을 방출하는 것! 정도로만 알아두자 라고 했는데요! 흠.. 좀 더 자세하게 공식 문서를 봅시다.

Publisher는 어떠한 요소(element)를 시간 흐름에 따라 방출합니다.

저는 처음에 ‘시간의 흐름에 따라’ 라는 문장이 직관적으로 다가오지 않았어요. 하지만 그림으로 보면 바로 이해가 될겁니다!

1초에 4 라는 값을 방출하고, 5초에 8이라는 값을, 8초 쯤에는 15라는 값을 방출하고 있다는게 보이나요? ‘시간의 흐름에 따라’ 이벤트가 방출되고 있죵?

이렇게 방출된 값은 하나 또는 그 이상의 Subscriber 에 전달됩니다!

한개의 Subscriber

다수의 Subscriber

이렇게 말이죠!

이때 Publisher<Int, Never>에 주목해볼까요? 바로 Publisher의 Output 과 Failure 타입입니다! 짐작할 수 있듯이 Output은 publisher가 방출하는 값의 종류이고 Failure은 publisher가 방출할 수 있는 에러의 종류입니다.

여기서는 Output은 Int형, Failure은 Never(Error가 발생할 일이 없다)가 되겠네요.

당연하게도 Subscriber 의 Input &Failure 의 associated type은 publisher의 Output &Failure 타입과 일치해야 합니다.

Type이 일치해야합니당

Protocol

그럼 publisher와 subscriber을 어떻게 연결할 수 있을까요? publisher는 subscriber를 받아들이기(accept) 위해 receive(subscriber:) 를 구현합니다. 해당 함수는 Publisher protocol에 정의되어 있어요~ 파라미터로 전달된 subscriber 는 해당 Publisher에서 방출하는 값들을 받을 수 있겠죠?

이후에 publisher는 아래와 같은 subscriber의 함수를 호출할 수 있어요! 이후 포스팅에서 더 자세히 설명하겠지만 가볍게 읽고 넘어가볼까요?

• receive(subscription:): subscriber에게 Subscription 인스턴스를 전달해줍니다! 이것을 이용해서 subscriber은 publisher의 elements를 요구하거나, 더 이상 값을 받지 않겠다고 할 수도 있어요~ Subscription은 subscriber와publisher의 연결을 나타내는것으로 볼 수 있겠죠?
• receive(_:): publisher에서 생성된 element를 subscriber로 전달하기 위해 쓰입니다.
• receive(completion:): subscriber 에게 이벤트 방출(publishing)이 정상적으로 또는 에러로 인해 끝났음을 알려줍니다.

참고로 Publisher의 Extensions은 많은 연산자(operator)를 제공하는데 이것들의 조합을 통해서 세련된 이벤트 처리 체인을 만들 수 있습니다. 각 operator은 Publisher 프로토콜을 타입을 반환하기 때문에 이러한 체인이 만들어질 수 있겠죠? 이러한 타입의 대부분은 Publishers enumeration의 extensions에 존재하는데요..! 예를 들어 map(_:) 연산자는 Publishers.Map 의 인스턴스를 리턴합니다. 잘 이해가 안된다면 이후 연산자 부분에서 다시 보면 되니까 그냥 넘어갑시다👉

Publisher의 종류

Convenience Publisher

• Future: 실패하거나 하나의 값을 방출한 후 완료됩니다.
• Just: 각각의 subscriber에게 딱 한 번 값을 방출하고 완료됩니다.

Future과 Just의 차이점을 보고 싶으면 여기를 참고하세요

• Empty: 어떤 값도 내보내지 않습니다. 즉시 종료될 수도 있습니다.
• Fail: 특정한 error와 함께 즉시 종료됩니다.

이 외에도 Deferred, Record 등이 있지만 써보지 않아서 해석하기 귀찮..어렵….ㅎㅎ 필요할때 써보면서 알아가기로 하죠~~ 하지만 영어 잘하는 존잘님들을 위해 일단 남기고 갑니다..해석해주세여🤗

• Deferred: A publisher that awaits subscription before running the supplied closure to create a publisher for the new subscriber.
• Record : A publisher that allows for recording a series of inputs and a completion, for later playback to each subscriber.

자신만의 Publisher 만들기

Combine 프레임워크에서 제공하는 타입들을 이용해서 자신만의 publisher를 만들 수도 있습니다. 아래의 방법들은 나중에 다시 설명할테니 일단 Publisher를 만드는 방법은 다양하구나.. 정도만 알고 가시면 됩니당😎

• PassthroughSubject와 같은Subject의 subclass를 만듭니다. send(_:) 의 호출을 통해 필요에 따라 값을 발행할 수 있습니다.
• 값이 업데이트 될 때마다 값을 발행하기 위해 CurrentValueSubject 를 사용합니다.
• 자신의 타입 중 하나의 프로퍼티에 @Published annotation 을 사용합니다. 이렇게 하면 프로퍼티의 값이 바뀔때마다 이벤트를 방출하는 publisher를 얻을 수 있습니다.

마무리

지금까지 Publisher에 대해 알아봤습니다!👏🏻 발행하는 애가 있다면 구독하는 애도 있어야겠죠? 짝꿍 Subscriber에 대해 알아보러 가봅시다! 고고링~~~

이전 포스팅 👈🏻

[Combine] Combine 시작하기

다음 포스팅 👉🏻

[Combine] Subscriber

참고

Publisher

[Swift] Combine 입문가이드2 — Publisher, Subscribe, Operator

Combine's Future