[Combine] Subscriber

구독🗞

시작하기 전에

오늘의 내용은 저번 포스팅의 내용과 겹치는 부분이 꽤 있어요! 만약 [Combine] Publisher 편을 읽지 않으셨다면 읽고 오시는걸 권해드려요!🤓

[Combine] Publisher

Subscriber

저번 포스팅에서는 Publisher를 알아봤으니 이제 Subscriber에 대해 알아볼 차례입니당. 공식 문서를 볼까요?

Publisher에서 나오는 요소의 흐름을 받는다.

저번 포스팅의 그림을 다시 한번 가져와 봅시다🚌 설명대로 Publisher에서 나오는 값들을 Subscriber가 받고 있네용. 하나의 Publisher에서 방출하는 값을 여러개의 Subscriber가 받을 수 있답니다.

한개의 Subscriber

다수의 Subscriber

Publisher<Int, Never>는 뭐를 뜻한다고 한지 기억하시나요? 바로 Publisher의 Output 과 Failure 타입을 나타낸다고 했어요. (헷갈린다면 꼭 여기에서 글을 읽고오세요!!)

Publisher에서는 Output과 Failure가 있듯이, Subscriber에는 Input과 Failure가 있답니다.

Publisher

• Output : publisher가 방출하는 값의 종류
• Failure : publisher가 방출할 수 있는 에러의 종류

Subscriber

• Input : subscriber가 받는 값의 종류
• Failure : subscriber 받을 수 있는 에러의 종류

따라서Subscriber 의 Input &Failure 의 associated type은 publisher의 Output &Failure 타입과 일치해야 합니다. 당연한 이야기죠???

여기까지는 다 Publisher 포스팅에서 같이 설명한 내용이에요.

Protocol

Subscriber protocol에는 위에서 설명한 Input, Failure 외에도 3개의 메소드가 정의되어 있어요! publisher는 상황에 따라 적절히 이 함수들을 사용하는 것이고요. 좀 더 자세히 알아볼까요?

receive(subscription:)

susbcriber와 publisher을 연결하기 위해subscribe(_:) 함수를 부르고 난 뒤에 publisher가 호출하는 함수입니다. 이 함수에서는 subscriber에게 Subscription 인스턴스를 전달해줍니다!

Subscription 은 subscriber와publisher의 연결을 나타냅니다! 이것을 통해서 subscriber은 publisher의 elements를 요구하거나, 아래 코드처럼 더 이상 값을 받지 않겠다고 할 수도 있어요~

subscription.cancel()

이렇게 subscription을 명시적으로 취소하지 않은면 publisher가 완료될때까지 또는 일반적인 메모리 관리로 인해 저장된 subscription이 초기화 되지 않을때까지 계속 유지된답니다.

receive(_:)

subscriber의 첫번째 요청(initial demand)이 이뤄지고 나면 publisher가 새롭게 발행된 element들을 subscriber로 전달하기 위해서 호출하는 함수입니다.

이때 subscriber의 첫번째 요청이란 subscriber가 Subscription protocol에 정의된 request(_:)를 호출하는 행위를 뜻해요. (아마!ㅎㅎ)

receive(completion:)

subscriber 에게 이벤트 방출(publishing)이 정상적으로 끝났는지 또는 에러로 인해 끝났음을 알려줄때 호출되는 함수입니다. 여기서 파라미터 타입은 Subscribers.Completion 입니당.

Subscriber 만들기

Subscriber를 상속받아 위와 같은 함수들을 직접 구현할 수도 있겠지만 우리의 애플은 이렇게 직접 구현하는 방법을 권장하지 않습니다. 대신 Combine 은 Publisher 타입의 operator를 통해 아래와 같은 subscriber을 제공하고 있어요! 🥳

• sink(receiveCompletion:receiveValue:): 종료 시그널을 받거나 매번 새로운 요소를 받았을때 임의적인 closure을 실행한다.
• assign(to:on:) : 매번 새로 받은 값을 주어진 인스턴스의 key path로 정의되는 property에 할당한다.

하지만 이런 것들은 일단 제쳐두고 직접 구현을 통해서 원리부터 알아보도록 합시다! 기본기를 조져보자!

과연..나의..미래는..?

마무리

다음 시간에는 Subscriber가 어떻게 Publisher에서 나온 값을 받는지에 대해 좀 더 자세한 설명과 예시를 통해 알아보도록 합시다. 그럼 다음 시간에 만나요!

이전 포스팅 👈🏻

[Combine] Publisher

다음 포스팅 👉🏻

[Combine] Subscribe

참고

Subscriber

Combine 시작하기(3)-Subscriber

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