DeferredObservableProperty

interface DeferredObservableProperty<T>

This interface is an asynchronous variation to the ObservableProperty. Used if the initial value is undefined. It doesn't provide a value if it hasn't been assigned yet, but you can block the thread until it is.

Types

Companion

object Companion

Listener

interface Listener<T> : ValueChangeListener<Optional<T>, T>

Implemented by listeners to DeferredObservableProperty value changes.

Functions

addListener

abstract fun addListener(listener: DeferredObservableProperty.Listener<T>): CancellationToken

Add a ValueChangeListener for value change on this property.

await

abstract suspend fun await(): T

Blocks the current thread to wait for a value if latestValue is null, otherwise returns latestValue immediately.

nextValue

abstract suspend fun nextValue(): T

Blocks the current thread until latestValue is replaced by a new value.

removeListener

abstract fun removeListener(listener: DeferredObservableProperty.Listener<T>)

Remove a ValueChangeListener from listeners to value change on this property.

Properties

latestValue

abstract val latestValue: Optional<T>

Returns the latest value if any was emitted, null otherwise.

Extensions

flatMapLatest

fun <T, U> DeferredObservableProperty<T>.flatMapLatest(equalityPolicy: ObservableProperty.EqualityPolicy<DeferredObservableProperty> = identityEqualityPolicy(), transform: (T) -> DeferredObservableProperty): DeferredObservableProperty

A mapping function applied to each element collected from the ObsrvableProperty to return a DeferredObservableProperty.

map

fun <T, U> DeferredObservableProperty<T>.map(equalityPolicy: ObservableProperty.EqualityPolicy = defaultEqualityPolicy(), transform: (T) -> U): DeferredObservableProperty

A mapping function applied to each element collected from the DeferredObservableProperty.

startWith

fun <T> DeferredObservableProperty<T>.startWith(initialValue: T): ObservableProperty<T>

Conversion method to synchronous ObservableProperty.