[Combine] Subscribe

구독하기🕵🏻‍♀️

이전 포스팅에서는 Publisher와 Subscriber에 대해 알아보았습니다! 안읽고 오셨다면 각각을 클릭해서 읽고 오시는게..도움이..될걸요..?🤔

자자..! subscriber는 어떻게 publisher를 구독하고 값을 받는걸까요?

바로protocol Publisher 에 정의되어 있는 subscribe(_:) 함수를 이용합니다. 이렇게 말이죠.

쨘~~ 이제 subscribe(_:) 함수의 인자로 들어간 subscriber는 publisher가 생산하는 값들을 받을 수 있게 되었습니다~~ 어때요 참 쉽죠?

사실 전 이거 본적 업읍니다..알지모답니다….

하지만 좀 더 들어가봅시다. 저 안에서는 어떤일들이 벌어지고 있는걸까요?🤔 차근차근 살펴보아요👣

배경

이해를 돕기위해 현생을 끌어와봅시다. 유튜브를 예로 들어볼게요.

요즘 가수 ‘러브송’님에게 입문해버렸다…

보다보니 우런니..노래 넘 잘부르고…ㅜㅜㅜ

앗,, 유투브도 하잖아?! 바로 구독해야지..

앞으론 우런니의 모든것..놓치지 않을거시다..

이런 상황을 아래와 같이 정리할 수 있을거예요.

나 = ‘러브송’님의 구독을 원하는 구독자 (subscriber)

러브송 = 컨텐츠 생산자 (publisher)

내가 지금 원하는 것 = ‘러브송’님 구독 (subscribe)

**막간 우런니 홍보**

우런니.. 러브송 치면.. 칠공주 러브송만 나와서 넘 속상해… 흰눈이 기쁨되는날.. 흰눈이 미소되는날…ㅠ ‍️

만약 세상 힙한척 하고 싶다… 나만 아는 좋은 노래 있고 십따.. 홍대병 말기다..하는 분들.. 구독..👍..🔔설정까지…! 🍈에서 스밍 백번 돌려..!!!!!!!!!

러브송LoveSong

과정

1. 먼저 ‘러브송’님(publisher)에게 구독을 요청해야겠죠? 이를 위해서 앞서 살펴보았듯, publisher에 딸린 subscribe(_:) 함수를 통해 subscriber의 구독을 요청합니다.

2. subscribe(_:) 의 구현부에서는 receive(subscriber:)라는 함수를 호출합니다. 이 함수는 Publisher 라면 모두 구현(implement)해야하는 함수로서 protocol Publisher에 정의되어 있습니다.

3. receive(subscriber:) 에서는 무엇을 할까요? 바로 publisher와 subscriber을 연결해줍니다. 어떻게요? 두 부분으로 나눠서 설명해 볼게요.

• 구독을 요청했으면 구독권이 필요하겠죠? 우선 subscription을 만듭니다.

• 이렇게 만들어진 subscription을 subscriber에게 전달하기 위해 subscriber의 receive(subscription:)을 호출합니다. 해당 함수는 protocol Subscriber에 정의되어 있습니다.

이렇게 publisher와 subscriber는 subscription 을 통해 연결됩니다.

4.receive(subscription:) 에서는 protocol Subscription 에 정의된 request(_:)을 호출하여 값을 최대로 얼만큼 받을 것인지 설정합니다. 함수의 parameter type이 Demand라는걸 기억해두세용. 5번에 다시 등장합니다!

3개 이상으로 값 들어올 수 없다!

protocol Subscription 에 정의된 걸 보니 subscriber가 받을 수 있는 최대 개수를 관리하는 것은 subscription 의 역할인가봉가? 라고 생각할수 있겠죠? subscription 의 역할을 좀 더 자세히 살펴볼까요?

• publisher에서 새로운 값이 발생했을 때 publisher 와 subscriber 을 중재하고 subscriber가 요청한 것보다 더 많은 값을 받지 않도록 보장합니다
• subscribers 의 유지 및 해제를 관리합니다

5.subscriber의 receive(_:)를 통해 publisher가 방출하는 새로운 값들을 전달할 수 있습니다. 따라서 이 함수는 여러번 호출 될 수 있습니다.

방금 4번에서subscription.request(_:) 를 통해 subscriber가 받을 수 있는 값의 최대 개수를 지정했었죠? 이때 parameter 타입이 Demand 인걸 기억하라고 했어요! 왜냐면 receive(_:) 의 반환 타입도 Demand 이기 때문입니다! 이를 통해서 처음에 subscriber가 받을 수 있는 최대 개수를 정하더라도 새 값을 받을 때마다 최대 값을 조절할 수 있어요! 새롭게 설정한 max 값이 기존의 max 값에 추가됩니다. 따라서 새 값을 받을 때마다 기존의 max 값을 늘릴 수 있지만 줄일 수는 없겠죠?

6. 만약 publisher가 더 이상 값을 생성하지 않거나 error가 발생한다면 subscriber의 receive(completion:)을 호출을 통해 종료를 알립니다.

흐름도

지금까지 설명한 내용을 흐름도로 나타내면 아래와 같아요~

조금 더 정확히는 publisher와 subscriber 사이에 subscription이 생성되고 나면 이것을 매개체로 해서 이후의 동작들이 일어난다고 보면 될거 같습니다. (아마? ㅎ🤔)

예제 코드

좋아요! 이제 직접 구현하는 일만 남았군여.. 직접 구현의 좋은점은 모든 라이프사이클을 확인할 수 있다는 점이져~~~~

출력은 아래와 같이 됩니다.

——— Example of: Custom Subscriber ———
Received value 1
Received value 2
Received value 3

또잉? publisher 는 1부터 6까지 값을 방출할텐데 왜 세 개 밖에 안찍힌담?? 바로 초기 요청에서 max 값을 지정해줬기 때문이죠!

subscription.request(.max(3))

처음에 설정한 max 값을 중간에 변경하고 싶다?? 하면 receive(_:) 함수 안을 변경해주면 됩니다. 위에서 receive(_:)를 설명할때 이런 내용이 있었답‍니다👆🏻

처음에 subscriber가 받을 수 있는 최대 개수를 정하더라도 새 값을 받을 때마다 최대 값을 조절할 수 있어요! 새롭게 설정한 max 값이 기존의 max 값에 추가됩니다. 따라서 새 값을 받을 때마다 기존의 max 값을 늘릴 수 있지만 줄일 수는 없겠죠?

따라서 receive(_:) 의 return 값을 .none 에서 .unlimited로 변경해볼게요. 이름에서부터 알수 있다시피 publisher가 생산할 수 있는 최대로 받아버리겠다..는 의미…! (A request for as many values as the publisher can produce.)

func receive(_ input: Int) -> Subscribers.Demand {
  print("Received value", input)
  return .unlimited
}

쨘🧚🏻‍♀️ 출력 결과가 변했습니다

——— Example of: Custom Subscriber ———
Received value 1
Received value 2
Received value 3
Received value 4
Received value 5
Received value 6
Received completion finished

만약 .unlimited를 .max(1)으로 변경하고 다시 실행한다면? 새롭게 설정한 max 값이 기존의 max 값에 추가된다고 했으니 이벤트를 받을 때마다 max 값은 1씩 계속 늘어나겠죠?? 때문에 6개 값이 모두 찍힐거예요!

마무리

이렇게 Subscriber를 상속받아 직접 구현한 custom subscriber 을 이용해 publisher를 구독해봤어요! 하지만 이전 포스팅에서도 언급했듯이 애플은 이런 방법으로 구현하는 것을 권장하지 않는답니다~ 대신 Combine에서는 Sink, Assign 등의 기본 Subscriber를 제공하고 있고 Publisher protocol에 정의된 sink나 assign 함수를 이용해서 각각의 subscription을 간단히 구현할 수 있어요!

지금도 충분히 글이 긴 것 같으니..! 이 방법들은 다음 포스팅에서 소개하겠습니다. 그럼 20000!

이전 포스팅 👈🏻

[Combine] Subscriber

다음 포스팅 👉🏻

[Combine] sink & assign

참고

잔망스러운 신입의 주간 iOS 개발 일지 #3

learncombine/Combine101

Understanding Combine’s publishers and subscribers — Donny Wals

Introducing Combine 정리

Subscriber

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

receive(subscriber:)

Publisher

Combine 시작하기(3)-Subscriber

Creating a custom Combine Publisher to extend UIKit — SwiftLee