[iOS] RxSwift - Subject vs Observable

곰튀김님 강의 [3교시] RxSwift 활용범위 넓히기에 해당하는 내용입니다!

 

💡 RxSwift - Observable vs Subject 

Observable 은 어떤 데이터를 내보내야할지 미리 정해진 형태의 스트림이다. create 하는 시점부터 값이 정해져있고, 중간에 데이터 값을 변경할 수 없다. 

 

버튼 조작으로 데이터 값을 변경해야하는 등의 상황에서는 Observable 대신 Subject 를 이용하면 된다. Subject 는 Observable 외부에서 데이터를 넣어줄 수도 있고, 구독할 수도 있는 양방향성을 가진 타입이다!

 

Subject 는 일반 Observable 처럼 subscribe 하여 event 를 전달받을 수 있음과 더불어, Subject 외부에서 onNext, onCompleted, onError, onDisposed 등을 통해 데이터를 전달하거나 stream 을 끊을 수 있다!

 

🌱정리하자면,
Rx 에서 Subject 는 Observable 이면서 Observer 인 타입이다.
Observable 이기 때문에, 이를 구독하는 Observer 에게 event 를 전달할 수 있으며
Observer 이기 때문에, 하나 이상의 Observable을 구독할 수 있으며 event 에 대한 처리를 할 수 있다.

---

👀 Subject 종류들 - Publish, Behavior, Async, Replay

Subject 는 여러곳에서 subscribe 할 수 있으며, 곰튀김님 강의에 의하면 Publish, Behavior 를 가장 많이 사용한다고 합니다. 

 

1. Publish Subject (is known simply as a subject)

• PublishSubject 는 subscribe 이후에 observable 들이 방출한 데이터만 observer 에게 방출한다.
• observer 가 subscribe 한 시점 이후에 생성된 데이터만 전달받을 수 있다.
• 마블 다이어그램을 보면, 첫번째 observer 는 구독한 시점 이후 빨강, 초록, 파랑 데이터를 전부 전달받지만, 두번째 observer 는 구독한 시점 이후에 방출된 파랑 데이터만 전달받는다.

Publish Subject 단점!?

• subject 가 생성되는 시점과 observer 가 subject 를 구독하는 시점 사이에 배출되는 항목들은 잃어버릴 수 있다는 단점이 있다.
• 위의 단점을 해결하기 위해 구독하는 시점에 기본값 or 마지막값을 전달받는 Behavior Subject 혹은 모든 데이터를 전달받을 수 있는 ReplaySubject 를 이용할 수 있다.

 

2. Behavior Subject

• observer 가 BehaviorSubject 를 구독하면, 가장 최근의 데이터 혹은 (최근 데이터가 없다면) 기본 값을 방출한다. 그 이후의 동작은 Publish Subject 와 동일하다.
• Observer 에 구독하는 시점은 다르지만 이전에 방출된 데이터를 가져올 필요가 있을 때, 이용하면 될 것 같다.
• BehaviorSubject 를 이용하면, PublishSubject 에서 데이터가 방출되기 전까지 아무 값도 가질수 없는 문제를 해결할 수 있다!
• 마블다이어그램을 살펴보면, 첫번째 observer 에게는 분홍색의 기본값이 전달되고 두번째 observer 에게는 가장 최근값인 초록색이 전달되는 것을 확인할 수 있다. 

3. AsyncSubject

• AsyncSubject 는 completed 되는 시점에 마지막 데이터 하나만 방출한다. 데이터가 생성되더라도 바로 내려주지 않는다.
• 만약 subject 가 구독하는 observable 이 오류로 인해 종료된 경우, AsyncSubject 는 아무것도 배출하지 않고 발생한 오류를 그대로 전달한다.
• 마블 다이어그램에서 | 으로 표시된 것은 observable 의 completed 시점을 의미한다. 

4. ReplaySubject 

• ReplaySubject 는 새롭게 구독하는 observer 에게 기존에 방출되었던 데이터들을 다시 전달한다. 데이터 emit 을 replay 한다고 생각하면 이해가 쉬울듯 하다!
• 생성시 bufferSize 를 지정해, 구독시 전달할 데이터의 개수를 지정할 수 있다.
• 마블 다이어그램을 보면 첫번째 observer 는 구독 이후에 데이터가 생성되었으므로, 방출 시점에 전달받는다. 두번째 observer 는 구독하는 시점에 이전 방출된 데이터를 한번에 전달받고, 그 이후 새로운 데이터도 전달받는다. 

 

5. Variable ?

• 몇몇 참고글에서는 Variable 도 Subject 의 종류로 함께 정리되어 있었지만, Reative 문서에 없어 찾아본 결과 
• RxSwift4.0 부터 variable 은 deprecated 되었고, 이와 동일한 기능의 BehaviorRelay 가 새로 나왔다고 한다.
• 추후에 Relay 관련하여 정리할 때 추가하겠습니다!

---

 

 

ReactiveX - Subject

songda515/MVVM_RxSwift