RendezvousStateFlow

open class RendezvousStateFlow<T>(initialValue: T) : MutableStateFlow<T>

A simple wrapper for waiting for an event to be fully processed by the listeners.

Constructors

fun <T> RendezvousStateFlow(initialValue: T)

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

suspend fun collectHolding(collector: suspend (T) -> Unit)

Allows the posting event to await the result of this listener.

open override fun compareAndSet(expect: T, update: T): Boolean

open suspend override fun emit(value: T)

fun emitAsync(value: T): Deferred<Unit>

Returns a deferred wrapper for the emit function.

@ExperimentalCoroutinesApi

open override fun resetReplayCache()

open override fun tryEmit(value: T): Boolean

open override val replayCache: List<T>

open override val subscriptionCount: StateFlow<Int>

open override var value: T