kotlinx-coroutines-core/kotlinx.coroutines.flow/AbstractFlow/collect

collect

suspend override fun collect(collector: FlowCollector<T>)(source)

Accepts the given collector and emits values into it.

This method can be used along with SAM-conversion of FlowCollector:

myFlow.collect { value -> println("Collected $value") }
Content copied to clipboard

Method inheritance

To ensure the context preservation property, it is not recommended implementing this method directly. Instead, AbstractFlow can be used as the base type to properly ensure flow's properties.

All default flow implementations ensure context preservation and exception transparency properties on a best-effort basis and throw IllegalStateException if a violation was detected.