BlockingChain
A chain with blocking generator that could be used without suspension
Inheritors
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Create a copy of current chain state. Consuming resulting chain does not affect initial chain.
Link copied to clipboard
inline fun <T, R> Flow<T>.mapParallel(dispatcher: CoroutineDispatcher = Dispatchers.Default, crossinline transform: suspend (T) -> R): Flow<R>
Link copied to clipboard
Get the next value without concurrency support. Not guaranteed to be thread safe.
Link copied to clipboard
Link copied to clipboard