asFlux

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

Deprecated: Deprecated in the favour of consumeAsFlow()

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

Every subscriber receives values from this channel in fan-out fashion. If the are multiple subscribers, they’ll receive values in round-robin way.

Parameters

context - – the coroutine context from which the resulting flux is going to be signalled