kotlinx-coroutines-reactive / kotlinx.coroutines.experimental.reactive / kotlinx.coroutines.experimental.channels.ReceiveChannel

Extensions for kotlinx.coroutines.experimental.channels.ReceiveChannel

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

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