kotlinx.coroutines.experimental.rx1.kotlinx.coroutines.experimental.channels.ReceiveChannel

fun <T> ReceiveChannel<T>.asObservable(
    context: CoroutineContext
): Observable<T>

Converts a stream of elements received from the channel to the hot reactive observable.