onEachAsync

fun <T> Iterable<T>.onEachAsync(concurrency: Int = DEFAULT_CONCURRENCY, action: suspend (T) -> Unit): Flow<T>

Sources

Link copied to clipboard