[Swift] Combine - Subject

Why ?

---

• 알고 사용하기 위해서 하나씩 정리해보고 맛보려고한다.
• Combine 핵심 프로토콜 중 Subject에 대해 알아보자!

Subject ?

---

• Publisher를 채택한 프로토콜이다.
• 스트림에 send(_:) 메소드를 호출해서 값을 주입할 수 있는 Publisher다.
• Combine을 사용하지 않던 코드에 Combine모델을 적용하고 싶을 때 사용하면 좋다고 한다.

@available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
public protocol Subject : AnyObject, Publisher {
    func send(_ value: Self.Output)
    func send(completion: Subscribers.Completion<Self.Failure>)
    func send(subscription: Subscription)
}

extension Subject Where Self.Output == Void {
    public func send()
}

• 3 개의 send 메소드와 Output이 Void일 때 필요한 send() 메소드가 구현되어 있다.
• send 메소드는 value, completion, subscription을 보내기 위한 것들이 있다.
• Subject 프로토콜의 concrete implementation이 2개 있다.
  • CurrentValueSubject
  • PassthroughSubject

CurrentValueSubject

---

• Single value를 래핑하고 값이 변경될 때마다 새 element를 publish하는 subject이다.
• PassthroughSubject 와 달리 CurrentValueSubject는 가장 최근에 publish된 element의 버퍼를 유지한다.
• CurrentValueSubject에서 send를 호출하면, 현재 값도 업데이트 되므로 값을 직접 업데이트 하는 것과 같다.

func combinePractice() {
    let currentValueSubject = CurrentValueSubject<String, Never>("Harry")
    let subscriber = currentValueSubject.sink(receiveValue: { print($0) })
    
    currentValueSubject.value = "안녕~"
    currentValueSubject.send("하이~")
}

combinePractice()

/* 
Harry
안녕~
하이~
*/

• 생성할 때 초기값을 주어야한다.

PassthroughSubject

• downstream subscribers에게 element를 broadcast하는 subject이다.
• 가장 최근에 publish된 element의 초기값 또는 버퍼가 없다.
• subscribers가 없거나 현재 demand가 0이면 value를 삭제한다.

func passthroughSubject() {
    let passthroughSubject = PassthroughSubject<String, Never>()
    let subscriber = passthroughSubject.sink(receiveValue:  { print($0) })
    
    passthroughSubject.send("안녕")
    passthroughSubject.send("Harry")
}

passthroughSubject()

/* 
안녕
Harry
*/

Reference

https://zeddios.tistory.com/965?category=842493