Package-level declarations

Functions

Link copied to clipboard
@API(status = API.Status.EXPERIMENTAL, since = "4.0.0")
fun <T, R> Flow<T>.concurrentMap(scope: CoroutineScope, concurrencyLevel: Int, transform: suspend (T) -> R): Flow<R>
Link copied to clipboard
@API(status = API.Status.EXPERIMENTAL, since = "4.0.0")
inline fun <T, R> Flow<T>.mapInOrder(concurrencyLevel: Int, crossinline map: suspend (T) -> R): Flow<R>