EventBus wrapper in RxJava

RxBus.kt

package ***

import io.reactivex.subjects.PublishSubject
import java.util.*

class RxBus {
    companion object {
        val instance = RxBus()
        private val subject = PublishSubject.create<Any>()
    }

    /**
     * Pass any event down to event listeners.
     */
    fun post(obj: Any){
        subject.onNext(obj)
    }

    /**
     * Subscribe to this Observable. On event, do something
     * e.g. replace a fragment
     */
    fun getEvent(): PublishSubject<Any>? {
        return subject
    }
}