Companion

object Companion

Functions

Link copied to clipboard
fun <O> create(scope: CoroutineScope, process: (Unit) -> Flow<O>): CancellableProcessFlow<Unit, O>
fun <I, O> create(scope: CoroutineScope, inputData: Flow<I>, process: (I) -> Flow<O>): CancellableProcessFlow<I, O>