RxBus2 - Kotlin

RxBus2

import io.reactivex.Observable
import io.reactivex.subjects.PublishSubject
import io.reactivex.subjects.Subject

/*
 * @Author: Hasiy
 * @Date: 2019/12/25 - 14 : 37 
 * @Description: Android
 * @Email: Hasiy.jj@gmail.com
 */
class RxBus2 private constructor() {
    private val bus: Subject<Any> = PublishSubject.create<Any>().toSerialized()
    // toSerialized method made bus thread safe

    private object Holder {
        val BUS = RxBus2()
    }

    fun post(obj: Any?) {
        if (obj != null) {
            bus.onNext(obj)
        }
    }

    fun <T> toObservable(tClass: Class<T>?): Observable<T> {
        return bus.ofType(tClass)
    }

    fun toObservable(): Observable<Any> {
        return bus
    }

    fun hasObservers(): Boolean {
        return bus.hasObservers()
    }

    companion object {
        val instance: RxBus2
            get() = Holder.BUS
    }
}