Subscriber와 Subscription

Subscriber

Subscriber는 Publisher에서 나오는 요소(element)의 흐름을 받습니다.

값을 받기만 하는 소비자의 역할입니다. Publisher(값 방출)와 Subscriber(값 받음)를 합치면 RxSwift의 Subject(값을 주고 받음) 의 역할과 동일하게 됩니다.

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

Subscription

• 전달자를 의미합니다.
  • subscription 프로토콜
  • 프로토콜을 준수하는 오브젝트
  • publisher, operator, subscriber의 전체 chain
• subscription의 끝에 subscriber를 추가함으로써 체이닝의 맨 앞에 있는 publisher를 활성화할 수 있습니다.
• output을 수신해줄 subscriber가 없으면 publisher는 어떤 value도 전달하지 않습니다.
• Publisher에서 새로운 값이 발생했을 때 Publisher와 Subscriber를 중재해 Subscriber가 요청한 값보다 더 많은 값을 받지 않도록 보장해줍니다.
• Subscribers의 유지 및 해제를 관리합니다.

Protocol

Subscriber는 다음과 같이 구현되어 있습니다.

@available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
public protocol Subscriber : CustomCombineIdentifierConvertible {
    associatedtype Input
    associatedtype Failure: Error
    
    func receive(subscription: Subscription)
    func receive(_ input: Self.Input) -> Subscribers.Demand
    func receive(completion: Subscribers.Completion<Self.Failure>
}