FlowCollector
interface FlowCollector<in T>
(source)FlowCollector is used as an intermediate or a terminal collector of the flow and represents an entity that accepts values emitted by the Flow.
This interface should usually not be implemented directly, but rather used as a receiver in a flow builder when implementing a custom operator. Implementations of this interface are not thread-safe.
Functions
Collects the value emitted by the upstream. This method is not thread-safe and should not be invoked concurrently. |
Extension Properties
val FlowCollector<*>. |
|
val FlowCollector<*>. |
Extension Functions
fun FlowCollector<*>. |
|
suspend fun <T> FlowCollector<T>.emitAll( Emits all elements from the given channel to this flow collector and cancels (consumes)
the channel afterwards. If you need to iterate over the channel without consuming it,
a regular suspend fun <T> FlowCollector<T>.emitAll(flow: Flow<T>): Unit Collects all the values from the given flow and emits them to the collector.
It is a shorthand for |
Inheritors
interface MutableSharedFlow<T> : A mutable SharedFlow that provides functions to emit values to the flow.
An instance of |