collect

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