[Swift Combine Basics] Subject 🙋‍♀️🙋‍♂️

Subject는 Subscriber이며 동시에 Publisher이며 Value이다.

A subject can receive values from an upstream publisher, and also can pass along these values to its downstream subscribers.

: Subject는 업스트림 발행자로부터 값을 전달받을 수도 있고, 다운스트림 구독자에게 값을 전달할 수도 있다. 또 값을 가지고 있을 수도 있다.

dafuq? 🤨

Subjects 에는 2가지 종류가 있는데, 우선 그 중 하나인 PassThroughSubject로 만든 예시를 한번 보자.

아래는 PassThroughSubject 가 구독자 역할을 하는 모습이다.

// 발행자
let publisher = [1, 2, 3].publisher

// 구독자 역할을 할 passthroughsubject
let passThroughSubject = PassThroughSubject<Int, Never>()

// 둘을 엮으려면 - AnySubscriber(s: Subject)를 활용할 수 있다. 
// (PassThroughSubject는 Subject 프로토콜을 준수한다.)
let anySubscriber = AnySubscriber(passThroughSubject)

// PassThroguhSubject를 이용하여 구독관계가 성립된 모습 (Subject의 구독자 역할)
publisher.receive(subscriber: anySubscriber)

이번에는 발행자 역할을 하는 모습이다.

// 발행자 역할을 할 PassThroughSubject
let passThorughSubject = PassThroughSubject<Int, Never>()

// sink() 메서드를 통해 해당 passThroughSubject와 연결되어있는 다운스트림 구독자를 생성할 수 있다.
// 값을 구독자에게 내려다주기 때문에 여기서는 발행자 역할을 한다.
let newSubscriber = passthroughSubject
            .sink { value in
              print(value)
            }

이런식으로 subject는 두가지 역할을 다 할 수 있는 SOLID 원칙에 위배되는 고마운 친구.

위에서 Subject에는 두가지 종류가 있다고 했는데, 이제는 이 두가지에 대해 알아보자.

첫번째로 좀전에 예시에서 만났던 PassThroughSubject , 두번째로 CurrentValueSubject 가 있다.

둘다 공통적으로 Subject 프로토콜을 채택하여 앞서 보았듯이 발행자 및 구독자 역할을 소화해낼 수 있다.

발행자 역할의 관점에서 두 subject의 다른 점이 있다면 CurrentValueSubject 는 초기값이 있고, PassThroughSubject 는 초기값이 없고 발행을 시작한 시점부터 값이 있다는 점이다.

CurrentValueSubject 는 아래와 같이 생성시에 초기값을 담아야한다.

let currentSubject = CurrentValueSubject<Int, Never>(99)

PassThroughSubject 는 생성시에는 초기값을 담을 수 없다.

let passthroughSubject = PassthroughSubject<Int, Never>()

이러한 둘의 차이때문에, 다음과 같은 차이가 파생된다.

"CurrentValueSubject 는 구독이 시작되는 시점에 초기값이 게시가 되기 때문에 연결이 되자마자 값이 구독자에게 전달되지만, PassThroughSubject는 구독이 시작되고, 그 후에 값이 게시가 되었을 때 구독자에게 값이 전달된다."

이게 무슨말인지는 아래의 예시를 보면 한번에 이해가 갈 것이다. 우선은 CurrentValueSubject 의 동작을 살펴보자

// message 문자열 변수값을 담은 currentValueSubject를 생성한다. 여기서 message는 초기값이다.
let message = "넷플릭스 구독이 시작되었음을 알리는 메시지입니다. 서비스를 바로 이용하셔도 됩니다."
let currentValueSubject = CurrentValueSubject<String, Never>(message)

// sink()메서드를 통해 구독자를 바로 연결한다. 
// 구독자와 연결이 된 직후 발행자는 값을 게시하므로, currentValueSubject는 초기값인 message	값을 다운스트림 구독자에게 전달한다.
// 다운스트림 구독자는 해당 값을 받아서 print 한다.
let subscriber = currentValueSubject
		.sink { message
                   print(message)
	         }

// 두번째 값을 게시한다. - 구독자는 다시한번 전달받은 값을 print 한다
currentValueSubject.send("새로운 영화 및 드라마가 출시되었습니다. 지금 바로 확인해보세요!")


// - Output -
// "넷플릭스 구독이 시작되었음을 알리는 메시지입니다. 서비스를 바로 이용하셔도 됩니다."
// "새로운 영화 및 드라마가 출시되었습니다. 지금 바로 확인해보세요!"

CurrentValueSubject 는 초기값을 가지고, 구독이 시작되는 순간 값을 다운스트림 구독자에게 전달한다.

위와 같은 동작을 PassThroughSubject로 동일하게 하려면 어떻게 해야할까?

앞서 말했듯이, PassThroughSubject 는 CurrentValueSubject 와 다르게 초기값이 없다.

그러므로 구독이 시작된 시점이 아닌 PassThroughSubject 가 값을 게시한 순간부터 값이 전달된다.

이번에도 역시 예제를 보면 이해가 단번에 될 것이다.

let passThroughSubject = PassThroughSubject<String, Never>()

// sink()메서드를 통해 구독자를 바로 연결한다. 
// 구독자와 연결이 된 직후 발행자는 값을 게시하지만, PassThroughSubject는 초기값이 없기때문에 다운스트림 구독자에게 전달되는 값이 없다.
let subscriber = passThroughSubject
                 .sink { message
		           print(message)
		 }


let messageA = "넷플릭스 구독이 시작되었음을 알리는 메시지입니다. 서비스를 바로 이용하셔도 됩니다."
let messageB = "새로운 영화 및 드라마가 출시되었습니다. 지금 바로 확인해보세요!"

// send()를 통해 값을 게시하여 값을 구독자에게 전달한다.
passThroughSubject.send(messageA)
passThroughSubject.send(messageB)


// - Output -
// "넷플릭스 구독이 시작되었음을 알리는 메시지입니다. 서비스를 바로 이용하셔도 됩니다."
// "새로운 영화 및 드라마가 출시되었습니다. 지금 바로 확인해보세요!"

Completion Event - 서비스 종료 🔚

Subject는 completion 이벤트를 받으면 더이상 값을 받지 않는다.

이는 마치 월간 구독 서비스를 이용하는 구독자에게 서비스가 끝났음을 알리고, 구독 서비스는 새로운 월간 구독 상품을 출시한다. 서비스가 종료된 구독자는 더이상 해당 서비스의 구독 상품을 받아볼 수 없고, 마지막으로 받아본 상품을 가지고 있는 것 유사하다고 볼 수 있겠다.

let currentValueSubject = CurrentValueSubject<Int, Never>(1)
print(currentValueSubject.value)
// 1

currentValueSubject.send(2)
print(currentValueSubject.value)
// 2

currentValueSubject.send(completion: .finished)

currentValueSubject.send(10)

print(currentValueSubject.value)
// 10이 아닌 2를 출력한다 

장단점 ➕➖

장점 :

• @Published 와는 다르게 Protocol 선언에 사용이 가능하다. (Property wrapper는 프로토콜 안에서 사용이 불가능하다)

• @Published 와는 다르게 error type 사용이 가능하다.

단점:

• 코드가 약간 길어진다 (?)

이 부분에 대해서는 추가적인 조사가 필요하다 🧪