OnlyOnceFlow

class OnlyOnceFlow<T>(value: T) : Flow<T>

This Flow implementation represents a flow that emits exactly one value during its lifetime.

value

the value to emit on the flow

Constructors

fun <T> OnlyOnceFlow(value: T)

open suspend override fun collect(collector: FlowCollector<T>)

gives the MessageEvent.data as Flow of Blob

val Flow<MessageEvent>.data: Flow<Any?>

gives the MessageEvent.data as Flow of Any

infix fun <A> Flow<A>.handledBy(handler: Handler<A>)

Connects a Flow to a Handler.

infix fun <A> Flow<A>.handledBy(execute: suspend (A) -> Unit): Job

Connects a Flow to a suspendable execute function.

fun <E : Event> Flow<E>.preventDefault(): Flow<E>

fun <E : Event> Flow<E>.stopPropagation(): Flow<E>

Checks if a Flow of a List of ValidationMessages is valid.