NonNullFlowWrapper

open class NonNullFlowWrapper<T : Any>(origin: Flow<T>) : Flow<T>

Types

Companion
Link copied to clipboard
object Companion

Functions

collect
Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<T>)
watch
Link copied to clipboard
open fun watch(onNext: (T) -> Unit, onError: (Exception) -> Unit, onCompleted: () -> Unit, coroutineScope: CoroutineScope = MainScope()): FlowWrapperWatchToken

Inheritors

NonNullStateFlowWrapper
Link copied to clipboard

Extensions

collectWhileAttached
Link copied to clipboard
fun <T : Any> NonNullFlowWrapper<T>.collectWhileAttached(lifecycle: Lifecycle, collection: (T) -> Unit)