Extensions for kotlinx.coroutines.experimental.channels.ReceiveChannel
fun <E : Any> ReceiveChannel<E>.asStream(): Stream<E> Creates a Stream of elements in this ReceiveChannel. |
|
Applies the collector to the ReceiveChannel |