io.github.goquati/io.github.goquati.kotlin.util.coroutine

Package-level declarations

Functions

inline suspend fun <T, K, V> <Error class: unknown class><T>.associate(crossinline block: (T) -> <Error class: unknown class><K, V>): Map<K, V>

associateBy

inline suspend fun <T, K> <Error class: unknown class><T>.associateBy(crossinline keySelector: (T) -> K): Map<K, T>

associateByNotNull

inline suspend fun <T, K : Any> <Error class: unknown class><T>.associateByNotNull(crossinline keySelector: (T) -> K?): Map<K, T>

associateNotNull

inline suspend fun <T, K : Any, V : Any> <Error class: unknown class><T>.associateNotNull(crossinline valueSelector: (T) -> <Error class: unknown class><K?, V?>?): Map<K, V>

associateWith

inline suspend fun <T, V> <Error class: unknown class><T>.associateWith(crossinline valueSelector: (T) -> V): Map<T, V>

associateWithNotNull

inline suspend fun <T, V : Any> <Error class: unknown class><T>.associateWithNotNull(crossinline valueSelector: (T) -> V?): Map<T, V>

awaitAll

suspend fun <R1, R2> awaitAll(f1: suspend <Error class: unknown class>.() -> R1, f2: suspend <Error class: unknown class>.() -> R2): <Error class: unknown class><R1, R2>

suspend fun <R1, R2, R3> awaitAll(f1: suspend <Error class: unknown class>.() -> R1, f2: suspend <Error class: unknown class>.() -> R2, f3: suspend <Error class: unknown class>.() -> R3): <Error class: unknown class><R1, R2, R3>

filterFailure

fun <E> <Error class: unknown class><Result<*, E>>.filterFailure(): <Error class: unknown class><E>

filterNotEmpty

fun <T, C : Collection<T>> <Error class: unknown class><C>.filterNotEmpty(): <Error class: unknown class><C>

filterSuccess

fun <T> <Error class: unknown class><Result<T, *>>.filterSuccess(): <Error class: unknown class><T>

fun <T, E> <Error class: unknown class><Result<T, E>>.filterSuccess(errorHandler: (E) -> Unit): <Error class: unknown class><T>

getAndResetCollection

inline suspend fun <T, C : Collection<T>> <Error class: unknown class><C>.getAndResetCollection(defaultValue: C): C

getAndResetList

inline suspend fun <T> <Error class: unknown class><List<T>>.getAndResetList(): List<T>

getAndResetSet

inline suspend fun <T> <Error class: unknown class><Set<T>>.getAndResetSet(): Set<T>

getOrPutAsync

suspend fun <K, V> ConcurrentMap<K, CompletableFuture<V>>.getOrPutAsync(key: K, block: suspend (K) -> V): V

groupBy

inline suspend fun <T, K> <Error class: unknown class><T>.groupBy(keySelector: (T) -> K): Map<K, List<T>>

inline suspend fun <T, K, V> <Error class: unknown class><T>.groupBy(keySelector: (T) -> K, valueTransform: (T) -> V): Map<K, List<V>>

groupByNotNull

inline suspend fun <T, K : Any> <Error class: unknown class><T>.groupByNotNull(keySelector: (T) -> K?): Map<K, List<T>>

inline suspend fun <T, K : Any, V : Any> <Error class: unknown class><T>.groupByNotNull(keySelector: (T) -> K?, valueTransform: (T) -> V?): Map<K, List<V>>

isEmpty

suspend fun <T> <Error class: unknown class><T>.isEmpty(): Boolean

isNotEmpty

suspend fun <T> <Error class: unknown class><T>.isNotEmpty(): Boolean

launchJobs

fun <T> <Error class: unknown class>.launchJobs(nofWorkers: Int, block: suspend <Error class: unknown class>.(Int) -> T): List<<Error class: unknown class><T>>

launchWorker

fun <Error class: unknown class>.launchWorker(nofWorkers: Int, block: suspend <Error class: unknown class>.(Int) -> Unit): List<<Error class: unknown class>>

lazyAsync

fun <T> <Error class: unknown class>.lazyAsync(context: <Error class: unknown class> = EmptyCoroutineContext, block: suspend <Error class: unknown class>.() -> T): <Error class: unknown class><T>

loopCatching

fun <Error class: unknown class>.loopCatching(handler: (Throwable) -> Unit, block: suspend <Error class: unknown class>.() -> Unit): <Error class: unknown class>

mapParallel

fun <T, R> <Error class: unknown class><T>.mapParallel(concurrency: Int = DEFAULT_CONCURRENCY, block: suspend (T) -> R): <Error class: unknown class><R>

toBatchedFlow

fun <T> <Error class: unknown class><T>.toBatchedFlow(maxBatchSize: Int? = null): <Error class: unknown class><List<T>>

toReceiveChannel

suspend fun <T> Collection<T>.toReceiveChannel(): <Error class: unknown class><T>

suspend fun <T> Iterable<T>.toReceiveChannel(capacity: Int = Channel.UNLIMITED): <Error class: unknown class><T>

toResultCollection

suspend fun <T, E, C : MutableCollection<in T>> <Error class: unknown class><Result<T, E>>.toResultCollection(destination: C): Result<C, E>

toResultCollectionOr

inline suspend fun <T, E, C : MutableCollection<in T>> <Error class: unknown class><Result<T, E>>.toResultCollectionOr(destination: C, block: (Collection<E>) -> C): C

toResultList

suspend fun <T, E> <Error class: unknown class><Result<T, E>>.toResultList(destination: MutableList<T> = ArrayList()): Result<List<T>, E>

toResultListOr

inline suspend fun <T, E> <Error class: unknown class><Result<T, E>>.toResultListOr(destination: MutableList<T> = ArrayList(), block: (Collection<E>) -> List<T>): List<T>

toResultSet

suspend fun <T, E> <Error class: unknown class><Result<T, E>>.toResultSet(destination: MutableSet<T> = LinkedHashSet()): Result<Set<T>, E>

toResultSetOr

inline suspend fun <T, E> <Error class: unknown class><Result<T, E>>.toResultSetOr(destination: MutableSet<T> = LinkedHashSet(), block: (Collection<E>) -> Set<T>): Set<T>