DaleLaw

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

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

takahirom

import kotlinx.coroutines.experimental.channels.BroadcastChannel
import kotlinx.coroutines.experimental.channels.ConflatedBroadcastChannel
import kotlinx.coroutines.experimental.channels.ReceiveChannel
import kotlinx.coroutines.experimental.channels.filter
import kotlinx.coroutines.experimental.channels.map
import kotlinx.coroutines.experimental.launch
import javax.inject.Inject
import javax.inject.Singleton

STAR-ZERO

// compile "org.jetbrains.kotlinx:kotlinx-coroutines-android:0.16"
// compile "android.arch.lifecycle:runtime:1.0.0-alpha3"
// compile "android.arch.lifecycle:extensions:1.0.0-alpha3"
// kapt "android.arch.lifecycle:compiler:1.0.0-alpha3"

class AsyncLiveData<T> private constructor(private val exec: suspend () -> T) : LiveData<T>() {

    private var observer: Observer<T>? = null

    private var job: Job? = null