Package space.kscience.kmath.coroutines

Types

AsyncFlow
Link copied to clipboard
common
class AsyncFlow<T> : Flow<T>
Content copied to clipboard

Functions

async
Link copied to clipboard
common
fun <T, R> Flow<T>.async(dispatcher: CoroutineDispatcher = Dispatchers.Default, block: suspend CoroutineScope.(T) -> R): AsyncFlow<R>
Content copied to clipboard
collect
Link copied to clipboard
common
inline suspend fun <T> AsyncFlow<T>.collect(concurrency: Int, crossinline action: suspend (T) -> Unit)
Content copied to clipboard
suspend fun <T> AsyncFlow<T>.collect(concurrency: Int, collector: FlowCollector<T>)
Content copied to clipboard
map
Link copied to clipboard
common
fun <T, R> AsyncFlow<T>.map(action: (T) -> R): AsyncFlow<R>
Content copied to clipboard
mapParallel
Link copied to clipboard
common
inline fun <T, R> Flow<T>.mapParallel(dispatcher: CoroutineDispatcher = Dispatchers.Default, crossinline transform: suspend (T) -> R): Flow<R>
Content copied to clipboard

Properties

Math
Link copied to clipboard
common
val Dispatchers.Math: CoroutineDispatcher
Content copied to clipboard