core/dev.fritz2.core/OnlyOnceFlow

OnlyOnceFlow

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

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

Parameters

value

the value to emit on the flow

Constructors

constructor(value: T)

Properties

val Flow<MessageEvent>.arrayBuffer: Flow<ArrayBuffer>

gives the MessageEvent.data as Flow of ArrayBuffer

val Flow<MessageEvent>.blob: Flow<Blob>

gives the MessageEvent.data as Flow of Blob

val Flow<MessageEvent>.body: Flow<String>

gives the MessageEvent.data as Flow of String

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

gives the MessageEvent.data as Flow of Any

val <M : ValidationMessage> Flow<List<M>>.valid: Flow<Boolean>

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

Functions

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

fun <T> Flow<T>.whenever(condition: Flow<Boolean>): Flow<T?>

This extension method takes a boolean Flow that controls the forwarding of an initial flow: If it is true the current value will be passed further on the result flow, if it is false a null will appear instead.