kotlinx.coroutines.experimental.reactor.kotlinx.coroutines.experimental.channels.ReceiveChannel

fun <T> ReceiveChannel<T>.asFlux(
    context: CoroutineContext = DefaultDispatcher
): Flux<T>

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