Implement EventBus with Kotlin coroutine

EventBus.kt

object EventBus {
    val bus: BroadcastChannel<Any> = BroadcastChannel()

    fun send(o: Any) {
        launch {
            bus.send(o)
        }
    }

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

// To post an event:
EventBus.send(SomeEvent())


// To subscribe to an event:
var subscription = EventBus.asChannel<SomeEvent>()
launch(UI) {
    subscription.consumeEach { event ->
      // Handles the event...
    }
}

// To cancel a subscriber:
subscription.cancel()