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

CleanAndroidCode :: EventBus :: 0 BusSubscriber.kt

interface BusSubscriberContract {
    fun bus(bus: RxBus)
    fun <T : Any> subscribe(clazz: KClass<T>, callback: (T) -> Unit)
    fun unsubscribe()
}

open class BusSubscriber @Inject constructor() : BusSubscriberContract {

    val subscriptions = mutableListOf<Subscription>()

    private lateinit var bus: RxBus
    override fun bus(bus: RxBus) {
        this.bus = bus
    }

    override fun <T : Any> subscribe(clazz: KClass<T>, callback: (T) -> Unit) {
        subscriptions.add(bus.events(clazz.java).subscribe(callback))

    }

    override fun unsubscribe() {
        subscriptions.forEach { it.unsubscribe() }
        subscriptions.clear()
    }
}

CleanAndroidCode :: EventBus :: 1 GlobalBusSubscriber.kt

class GlobalBusSubscriber @Inject constructor(
        val bus: GlobalBus
) : BusSubscriber() {

    init {
        bus(bus)
    }
}

CleanAndroidCode :: EventBus :: 2 ActivityBusSubscriber.kt

@ActivityScope
class ActivityBusSubscriber @Inject constructor(
        val bus: ActivityBus
) : BusSubscriber() {

    init {
        bus(bus)
    }
}