[Combine] Combine 시작하기 - Publisher와 Subscriber

안녕하세요 제인입니다!

굉장히 오랜만에 글을 쓰는데... 컴바인으로 돌아왔습니다 ㅎ...

동아리 플젝으로 바빠서 블로그에 공부한 내용 정리를 못했는데,

동아리 후기도 가져오고 그동안 공부한 내용도 정리해서 올려보도록 할게요!

동아리 플젝에서 SwiftUI + Combine 으로 개발을 하게 되었는데요, 새로운 스택에 도전하니 재밌었습니다😆

더 깊게 공부해보면서 내용정리를 해보려구요 ! 오늘은 컴바인 시작하기로 Publisher와 Subscriber에 대해 정리해보겠습니다.

Combine 이란?

Combine은 Apple에서 공식적으로 제공하는 비동기 이벤트 처리를 위한 프레임워크입니다.

또 다른 비동기 처리 도구인 RxSwift는 third-party 라이브러리이지만 Combine은 Apple에서 공식적으로 제공해주는 프레임워크로, 2019년에 공개되어 iOS 13 이상부터 사용이 가능합니다!

 

공식문서의 소개를 번역해보면,

Combine은 이벤트 처리 연산자를 결합하여 비동기 이벤트 처리를 가능하게 하는 프레임워크 정도로 정의할 수 있겠네요!

개요

Combine 프레임워크는 시간에 따른 값 처리를 위한 선언적 Swift API를 제공합니다.

이 값들은 여러 종류의 비동기 이벤트를 나타낼 수 있습니다.

Combine은 시간에 따라 변경될 수 있는 값을 방출하는 publisher와 publisher로부터 값들을 전달받는 subscriber를 선언합니다.

 

Publisher 프로토콜은 일련의 값을 시간에 따라 전달할 수 있는 타입을 선언합니다.

Publisher는 upstream publisher로부터 받은 값에 대해 행동하고 이 값들을 republish하는 연산자들을 가집니다.

 

Subscriber는 publisher 체인의 끝에서 값들을 수신받을 때 동작됩니다.

subscriber들이 명시적으로 값을 요청할 때만 publisher들은 값을 방출합니다.

이를 통해 우리가 만드는 subscribers 코드는 연결된 publisher들로부터 얼마나 빨리 이벤트를 받는지 통제할 수 있습니다.

 

Timer, NotificationCenter 및 URLsession을 포함한 여러 Foundation 유형은 publisher를 통해 기능을 노출합니다.

또한, Combine은 Key-Value Observing을 준수하는 모든 속성에 대한 내장된 publisher를 제공합니다.

 

여러 publisher의 output을 결합하여 상호 작용을 조정할 수 있습니다. 예를 들어 text field의 publisher를 구독하고 텍스트 값의 변화에 따른 URL 요청을 수행할 수 있습니다. 그런 다음 다른 publisher를 사용하여 응답을 처리하고 앱을 업데이트할 수 있습니다.

 

Combine을 채택하면 이벤트 처리 코드를 중앙 집중화하고 중첩 클로저나 다른 타입들을 가진 콜백과 같은 문제를 제거함으로써 코드를 읽고 유지하기가 쉬워질 것입니다.

 

여기까지 공식문서 설명을 번역하며 Combine이 무엇인지 알아보았습니다.

Combine의 핵심이 되는 Publisher와 Subscriber에 대해 알아봅시다!

Publisher

시간이 흐름에 따라 일련의 값들을 전송(방출)할 수 있는 타입을 선언하는 프로토콜

protocol Publisher<Output, Failure>

 

하나의 publisher는 하나 혹은 여러 subscriber 인스턴스에게 요소들을 전달합니다.

subscriber의 Input과 Failure (associated type)는 각각 publisher의 Output 과 Failure 에 매치가 됩니다.

publisher는 subscriber를 받기 위해 receive(subscriber:) 메서드를 구현합니다.

📌 receive(subscriber:)
특정한 subscriber를 해당 publisher에 연결합니다.

func receive<S>(subscriber: S) where S : Subscriber, Self.Failure == S.Failure, Self.Output == S.Input

 

subscriber 파라미터의 구독자가 연결되고, 값을 받을 수 있게 됩니다.

Publisher의 구현를 위해서는 반드시 해당 메서드를 구현해야 합니다.

 

그러면 publisher는 subscriber에서 다음과 같은 메서드를 호출할 수 있습니다.

 

• receive(subscription:): 구독자에게 구독이 성공적으로 이루어졌고 아이템들을 요청할 수 있음을 알려주는 메서드. 구독 요청을 승인하고 Subscription 을 반환함. 구독자는 subscription을 이용해 publisher에게 element를 요구하고 이를 이용해 publishing 을 취소할 수 있다.
• receive(_:): 하나의 요소를 구독자에게 전달한다.
• receive(completion:): publishing이 정상적으로 또는 오류로 종료되었음을 구독자에게 알린다.

downstream 구독자(subscriber)들이 올바르게 작동하려면 모든 publisher가 해당 프로토콜(=Publisher)을 준수해야 합니다.

Publisher에 대한 extentension은 정교한 이벤트 처리 체인을 생성하기 위해 구성하는 다양한 연산자를 정의합니다.

각 연산자는 Publisher 프로토콜을 구현하는 타입을 반환합니다.

이러한 타입들 대부분은 Publishers 열거형에 대한 확장으로 존재합니다.

Subscriber

publisher 로부터 입력을 받을 수 있는 타입을 선언하는 프로토콜

protocol Subscriber<Input, Failure> : CustomCombineIdentifierConvertible

 

Subscriber 인스턴스는 Publisher로부터 둘 사이의 관계에 대한 변경을 설명하는 life cycle 이벤트와 함께 값의 스트림을 받습니다.

subscriber의 Input과 Failure associated type은 연결된 publisher의 Output과 Failure 와 일치해야 합니다.

 

publisher의 subscribe(_:) 메서드를 호출함으로써 subscriber를 publisher에 연결할 수 있습니다.

해당 메서드를 호출 후에는 publisher가 subscriber의 receive(subscription:) 메서드를 호출합니다.

이는 subscriber에게 값을 요청하고 선택적으로 구독을 취소하는데 사용되는 Subscription 인스턴스를 제공합니다.

subsriber가 최초의 요청을 한 후에는 새롭게 게시되는 요소들을 전달하기 위해 publisher는 비동기적으로 receive(_:)를 호출합니다.

publisher가 publishing을 중단하게 되면, subscriber는 Subsribers 타입의 파라미터를 사용하여 receive(completion:)을 호출합니다. Completion은 publishing이 정상적으로 완료되는지 혹은 오류가 발생했는지 여부를 나타냅니다.

 

Publisher 타입에 대한 연산자로 아래의 subsriber를 제공합니다.

 

• sink(receiveComplete:receiveValue:): 완료 신호와 새 요소를 수신할 때마다 임의의 클로저를 실행합니다.
• assign(to:on :): 새로 받은 값을 keyPath에 따라 주어진 인스턴스의 property에 할당합니다.

여기까지 Combine의 기본적인 내용에 대해 정리해보았는데요!

프로젝트 개발을 통해 적용하게 되는 내용들도 정리하면서 구체적인 사용방법, 예시에 대해서도 가져와보도록 하겠습니다~!!

---

[참고 자료]

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

https://ios-development.tistory.com/1113

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

https://brunch.co.kr/@tilltue/65