RxBus gist for CleanAndroidCode article series https://medium.com/@anton.averin.dev/keep-your-droid-clean-e9c093140eb6

CleanAndroidCode :: EventBus :: RxBus.kt

open class RxBus {
    private val bus = SerializedSubject<BusEvent, BusEvent>(PublishSubject.create());

    fun post(event: BusEvent) {
        bus.onNext(event)
    }

    fun <T> events(type: Class<T>): Observable<T> {
        return events().ofType(type)
    }

    fun events(): Observable<BusEvent> {
        return bus.asObservable()
    }
}