Convert BroadcastChannel(via Kotlin coroutines) to LiveData

BroadcastChannelExt.kt

package your.awesome.domain

import android.arch.lifecycle.LiveData
import android.arch.lifecycle.MutableLiveData
import kotlinx.coroutines.experimental.android.UI
import kotlinx.coroutines.experimental.channels.ConflatedBroadcastChannel
import kotlinx.coroutines.experimental.channels.ReceiveChannel
import kotlinx.coroutines.experimental.channels.consumeEach
import kotlinx.coroutines.experimental.launch

fun <T> ConflatedBroadcastChannel<T>.toLiveData() : LiveData<T> {
    val channel = this
    val liveData = object : MutableLiveData<T>() {

        private var subscription: ReceiveChannel<T>? = null

        override fun onActive() {
            super.onActive()
            val ld = this

            // Receive in UI thread
            launch(UI) {
                val receiveChannel = channel.openSubscription()
                subscription = channel.openSubscription()
                receiveChannel.consumeEach {
                    ld.postValue(it)
                }
            }

            // Emit latest value when on active
            val value = channel.valueOrNull
            if (value != null) {
                ld.postValue(value)
            }
        }

        override fun onInactive() {
            subscription?.cancel()
            subscription = null
            super.onInactive()
        }
    }

    return liveData
}