collect

suspend fun <T> AsyncFlow<T>.collect(concurrency: Int, collector: FlowCollector<T>)

Content copied to clipboard

inline suspend fun <T> AsyncFlow<T>.collect(concurrency: Int, crossinline action: suspend (T) -> Unit)

Content copied to clipboard