📚 TL; DR

📚 Cold Publisher / Hot Publisher

📖 Cold Publisher

• 구독자가 구독하는 시점에 데이터 방출을 시작하는 Publisher
• 구독자가 구독하는 시점에 데이터 발행을 시작하기 때문에, 모든 구독자는 동일한 데이터를 수신 받을 수 있음
• 앞서 살펴본 Single / Flowable / Observable 등이 이에 해당 됨

📖 Hot Publisher

• 구독자가 구독하지 않아도, 데이터를 방출하는 Publisher
• 구독자가 구독하지 않아도 데이터를 방출하기 때문에, 구독자가 구독하기 이전에 발행된 데이터는 구독자가 데이터를 받을 수 없음
• Processor / Subject 등이 이에 해당 됨
• 중복된 이벤트 발행을 막기 위해 사용 할 수 있음 ( MultiCasting / UniCasting, 추후 포스팅에서 Connectable Observable과 함께 다룰 예정 )

📚 Processor / Subject

📖 Processor / Subject

• Reactive Stream에서, Publihser / Subscriber를 동시에 구현하고 있는 interface
• 즉 관찰 대상으로도, 관찰자로써도 활용할 수 있도록 활용
• 앞서 살펴본 Observable / Flowable / Single 등과 다르게 Hot Publisher의 특성을 지님
• Flowable / Observable의 차이점과 마찬가지로, Processor는 배압을 활용할 수 있지만, Subject는 배압을 활용하지 못함
• RxJava2에는 Subject / Processor를 PublishSubject ( Processor ) / BehaviorSubject ( Processor ) / AsyncSubject ( Processor ) / ReplaySubject ( Processor ) 등으로 구현 해 둠

📖 PublishSubject

• 구독 시점 이전에 발행된 데이터는 무시하고, 구독 시점 이후에 발행된 데이터를 발행하는 Subject