Kotlin coroutine-based event bus

EventBus.kt

import kotlinx.coroutines.experimental.DefaultDispatcher
import kotlinx.coroutines.experimental.channels.BroadcastChannel
import kotlinx.coroutines.experimental.channels.ReceiveChannel
import kotlinx.coroutines.experimental.channels.filter
import kotlinx.coroutines.experimental.channels.map
import kotlinx.coroutines.experimental.launch
import kotlin.coroutines.experimental.CoroutineContext

class EventBus {

    private val channel = BroadcastChannel<Any>(1)

    fun send(event: Any, context: CoroutineContext = DefaultDispatcher) {
        launch(context) {
            channel.send(event)
        }
    }

    fun subscribe(): ReceiveChannel<Any> =
        channel.openSubscription()

    inline fun <reified T> subscribeToEvent() =
        subscribe().filter { it is T }.map { it as T }
}