oskit-kmp/com.outsidesource.oskitkmp.concurrency/KotlinNativeFlowWrapper

KotlinNativeFlowWrapper

class KotlinNativeFlowWrapper<T : Any>(flow: Flow<T>)

Constructors

Link copied to clipboard
constructor(flow: Flow<T>)

Functions

Link copied to clipboard
fun subscribe(scope: CoroutineScope, onEach: (item: T) -> Unit, onComplete: () -> Unit, onThrow: (error: Throwable) -> Unit): Job