Doc

구독 이후에 갱신된 값만 적용

이벤트버스로 활용

object ObservableRxBus {
	private val publisher = PublishSubject.create<Any>()

	fun publish(event: Any) {
		publisher.onNext(event)
	}

	@JvmStatic
	fun <T> listen(type: Class<T>): Observable<T> = publisher.ofType(type)
}

rxjava3 → toSerialized(): thread-safe역할

Subject 주의점