EventBus.kt

@ExperimentalCoroutinesApi
object EventBus {
    val bus: BroadcastChannel<Any> = BroadcastChannel(Channel.CONFLATED)

    suspend fun send(o: Any) = bus.send(o)

    inline fun <reified T> asChannel(): ReceiveChannel<T> {
        return bus.openSubscription().filter { it is T }.map { it as T }
    }
}