Extensions for kotlinx.coroutines.channels.ReceiveChannel

asFlux

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

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