[RxJava] #2 Subject

지난 포스팅에 이어서 RxJava의 Subject에 대해 알아보겠습니다

 

💡 Subject

• 구독자, 생성자의 특징을 둘 다 가짐 (여러개의 Observable을 구독할 수 있고,  데이터를 방출할 수 있다)

• Cold Observable을 Hot Observable로 변경

🔥 Hot Observable

데이터 구독 여부와 관계 없이 데이터를 배출

❄️ Cold Observable

데이터를 구독을 시작해야 데이터가 배출 

 

---

 

Subject의 종류

 

📍 AsyncSubject

 

AsyncSubject

 

• 해당 Observable이 완료된 후 마지막 데이터만 발행합니다

• 에러가 발생한다면 어떠한 데이터도 발행하지 않고, 에러만 발행합니다 

 

val subject: AsyncSubject<String> = AsyncSubject.create()
    subject.apply {
       onNext("first")
       onNext("second")
       subscribe { it -> Log.d("#1", it) }
       onNext("third")
       subscribe { it -> Log.d("#2", it) }
       onNext("fourth")
       subscribe { it -> Log.d("#3", it) }
       onComplete()
     }

 

---

 

📍 BehaviorSubject

BehaviorSubject

 

• 구독을 시작하면 가장 최근의 데이터를 발행한 후 그 후에 발행되는 항목들은 그대로 발행합니다 

• 만약 최근 데이터가 없다면 (처음 값 or default)를 발행합니다 

• 에러가 발생한다면 어떠한 데이터도 전달하지 않고, 에러만 전달합니다 

 

val behaviorSubject : BehaviorSubject<String> = BehaviorSubject.createDefault("default Value")
    behaviorSubject.apply {
        subscribe {
           Log.d("BehaviorSubject #1", it)
        }

        onNext("Kotlin")
        onNext("Java")
        onNext("Flutter")
        subscribe {
           Log.d("BehaviorSubject #2", it)
        }
        
        onNext("Python")
        onNext("C++")
        subscribe {
            Log.d("BehaviorSubject #3", it)
        }
     }

 

 

---

 

📍 PublishSubject

publishSubject

 

• 구독 시점 이후 방출되는 아이템만 발행합니다 (Hot Observable)

• subject 생성 시점, 구독 시점의 차이로 인해 데이터를 손실할 위험이 있습니다

    ▶️  Cold Observable로 만들거나 ReplaySubject을 사용해야합니다 

• 에러가 발생한다면 어떠한 데이터도 전달하지 않고, 에러만 전달합니다 

 

val publishSubject : PublishSubject<String> = PublishSubject.create()
publishSubject.apply {
   onNext("aaa")
   onNext("bbb")
   onNext("ccc")
   subscribe { Log.d("publishSubject #1", it) }
   
   onNext("AAA")
   onNext("BBB")
   subscribe { Log.d("publishSubject #2", it) }
   
   onNext("CCC")
   onComplete()
}

 

---

 

📍 ReplaySubject

ReplaySubject

 

• 구독을 시작하면 발행되었던 모든 데이터를 다시 발행합니다 

• 메모리 누수를 주의해야 합니다 

 

val replaySubject : ReplaySubject<String> = ReplaySubject.create()
replaySubject.apply {
   onNext("공지사항 1")
   subscribe { Log.d("replaySubject #1", it) }
   
   onNext("공지사항 2")
   onNext("공지사항 3")
   subscribe { Log.d("replaySubject #2", it) }
   
   onNext("공지사항 4")
   onNext("공지사항 5")
   subscribe { Log.d("replaySubject #3", it) }
   onComplete()
}

 

 

[참고자료]

https://reactivex.io/documentation/subject.html

ReactiveX - Subject

 

---

궁금하신 점이나 의견이 있으시면 댓글 부탁드립니다 감사합니다 😊