mapAsync

fun <T, R> Flow<T>.mapAsync(concurrency: Int = DEFAULT_CONCURRENCY, transform: suspend (T) -> R): Flow<R>
fun <T, R> Iterable<T>.mapAsync(concurrency: Int = DEFAULT_CONCURRENCY, transform: suspend (T) -> R): Flow<R>
fun <T, R> Sequence<T>.mapAsync(concurrency: Int = DEFAULT_CONCURRENCY, transform: suspend (T) -> R): Flow<R>

Sources

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard