Extensions for kotlinx.coroutines.channels.ReceiveChannel

asPublisher

fun <T> ReceiveChannel<T>.asPublisher(
    context: CoroutineContext = EmptyCoroutineContext
): Publisher<T>

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