Package modulecheck.utils.coroutines

Functions

suspend fun <T> Flow<T>.any(predicate: suspend (T) -> Boolean): Boolean

suspend fun <T> Flow<T>.contains(element: T): Boolean

fun <T> Flow<T>.distinct(): Flow<T>

fun <T> Iterable<T>.filterAsync(predicate: suspend (T) -> Boolean): Flow<T>

fun <T> Sequence<T>.filterAsync(predicate: suspend (T) -> Boolean): Flow<T>

fun <T> Flow<T>.filterAsync(predicate: suspend (T) -> Boolean): Flow<T>

suspend fun <T, R> Flow<T>.flatMapListConcat(destination: MutableList<R> = mutableListOf(), transform: suspend (T) -> List<R>): List<R>

suspend fun <T, R> Flow<T>.flatMapSetConcat(destination: MutableSet<R> = mutableSetOf(), transform: suspend (T) -> Set<R>): Set<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>

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

fun <T, R : Any> Iterable<T>.mapAsyncNotNull(transform: suspend (T) -> R?): Flow<R>

fun <T, R : Any> Sequence<T>.mapAsyncNotNull(transform: suspend (T) -> R?): Flow<R>

fun <T, R : Any> Flow<T>.mapAsyncNotNull(transform: suspend (T) -> R?): Flow<R>

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