[RxSwift] Subject

이전 포스팅에서 RxSwift 에 대한 기본적인 개념과 사용법을 알아봤는데요~!!

근데 한가지 의문점이 생기죠!

 

Observable을 구독하면서 데이터를 전달받기는 하는데, 반대로 Observable에 데이터 변화는 어떻게 줄 수 있을까요?

그래야 변경된 데이터를 다시 구독해서 User Interaction에 따라 뭔가 UI에 변화를 줄텐데요!

 

여기서 나온게 바로 Subject 입니다. 한번 Subject에 대해 알아볼까요~~~ 👉

 

---

reactivex.io/documentation/subject.html

ReactiveX - Subject

공식 문서에 Subject에 대해 잘 나와있는데, 간단하게 정리해볼게요!!

 

Subject는 Observable처럼 값을 배출할 수도 있지만, 구독도 할 수 있어요. 즉 Observable이면서 Observer이기도 한거죠.

Subject는 동적으로 값을 Control 및 배출할 수 있고, 구독하고 있는 "Observer들"에게 값을 배출합니다. (muticast 방식)

Observable과 차이점은 구독중인 하나의 Observer에게만 값을 배출한다는 차이점이 있어요. (unicast 방식)

 

 

Subject는 4가지 종류가 있어요.

 

 

PublishSubject

가장 일반적으로 사용하는 Subject에요.

Subject에 데이터가 생성되면 해당 Subject를 구독하는 Observer들에게 데이터를 배출해주는 방식으로 동작합니다.

 

** 예시

let publishSubject = PublishSubject<Int>()
        publishSubject
            .debug()
            .subscribe { print("first subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        publishSubject.onNext(1)
        publishSubject.onNext(2)
        
        publishSubject
            .debug()
            .subscribe { print("second subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        publishSubject.onNext(3)
        publishSubject.onNext(4)
        publishSubject.onCompleted()

하나의 subject가 구독할때 1,2 이벤트를 배출하고, 두번째 subject가 구독을 시작했어요.

두번째 subject는 구독 시점 이후에 발생한 이벤트인 3,4만 수신한 걸 볼 수 있어요.

 

 

BehaviorSubject

기본값을 하나 가지고 시작해요. 어떤 Observer가 구독 하자마자 기본값을 바로 배출해줘요.

만약 중간에 새로운 Observer가 구독하게 되면, 가지고 있던 최신 데이터를 바로 배출해주는 방식으로 동작해요.

 

** 예시

let behaviorSubject = BehaviorSubject<Int>(value: 100)
        behaviorSubject
            .debug()
            .subscribe { print("first subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        behaviorSubject.onNext(1)
        behaviorSubject.onNext(2)
        
        behaviorSubject
            .debug()
            .subscribe { print("second subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        behaviorSubject.onNext(3)
        behaviorSubject.onNext(4)
        behaviorSubject.onCompleted()

예상대로네요!!

초기값 100을 가지고 시작했고, 첫번째 subject가 구독하자마자 100 이벤트를 배출해줬습니다.

마찬가지로 두번째 subject가 구독을 하자마자 가지고 있던 최신 데이터인 2를 바로 배출해줬어요!!

 

 

 

AsyncSubject

여러 Observer가 구독하고 있는 도중에도, 중간에 데이터가 발생한다고 바로 배출해주지 않아요.

대신, 마지막에 Completed 이벤트가 발생했을때 가장 마지막에 발생한 데이터만 배출하는 방식으로 동작해요.

 

** 예시

func testAsyncSubject() {
        let asyncSubject = AsyncSubject<Int>()
        asyncSubject
            .debug()
            .subscribe { print($0) }
            .disposed(by: disposeBag)
        
        asyncSubject.onNext(1)
        asyncSubject.onNext(2)
        asyncSubject.onNext(3)
        asyncSubject.onCompleted()
    }

구독하는 도중에 1,2,3 데이터에 대한 Next 이벤트가 3번 발생했지만, 실제로는 마지막에 complete 이벤트가 호출될때 마지막에 생성된 3만 next이벤트로 배출되는 걸 볼 수 있어요.

 

 

ReplaySubject

기본적인 동작은 PublishSubject와 유사한데, 중간에 다른 Observer가 구독하기 시작하면 지금까지 발생했던 모든 데이터를 Buffer Size(몇개나 배출해줄건지) 배출해주고, 이후부터는 데이터가 발생할때마다 배출해주는 방식으로 동작합니다.

 

** 예시

let replaySubject = ReplaySubject<Int>.create(bufferSize: 2)
        replaySubject
            .debug()
            .subscribe { print("first subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        replaySubject.onNext(1)
        replaySubject.onNext(2)
        replaySubject.onNext(3)
        
        replaySubject
            .debug()
            .subscribe { print("second subscribe: \($0)") }
            .disposed(by: disposeBag)
        
        replaySubject.onNext(4)
        replaySubject.onCompleted()

네~!! 이것도 예상대로 입니다 👍

첫번째 subject가 구독을 시작하고 1,2,3 데이터를 배출해줬어요. 그때 두번째 subject가 구독을 시작했고, 지금까지 발생했던 데이터를 모두 수신하게 되는데요! 여기서 생성시점에 Buffer 크기를 2로 만들어 줬으니, 실제로 1~3의 3개의 데이터가 발생했었지만 최신 2개인 2,3에 대한 이벤트만 수신하는 걸 볼 수 있어요!

 

---

이번 포스팅에서는 Subject의 개념과 종류, 종류별로 어떻게 동작하는지 한번 알아보았습니다 😎

오늘도 누군가에게 도움이 되었길 바래요 🙏