ConditionalValue

open class ConditionalValue<T>(initValue: T)

A coroutine-based conditional waiter backed by MutableStateFlow.

Holds a value of type T and allows coroutines to suspend until the value satisfies an arbitrary predicate, with optional timeout support.

initValue

the initial value.

the type of the monitored value.

Constructors

constructor(initValue: T)

fun get(): T

Returns the current value.

suspend fun set(value: T)

Sets the value and yields to allow waiting coroutines to observe the change.

suspend fun waitUntil(timeoutDuration: Duration = Duration.INFINITE, predicate: (T) -> Boolean): Boolean

Suspends until the predicate becomes true or timeout occurs.