architecture/com.splendo.kaluga.architecture.observable/ObservationUninitialized

ObservationUninitialized

class ObservationUninitialized<T> : Observation<T, T, ObservableOptional<T>> , MutableUninitialized<T> , ReadWriteProperty<Any?, T?>

An Observation that implements MutableUninitialized

Parameters

T

the type of value to expect.

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
var beforeObservedValueGet: (ObservableOptional<T>) -> ObservableOptional<T>?

Transformation to apply to the latest value when observedValue is called.

Link copied to clipboard
val currentObserved: ObservableOptional<T>

The currently observed OO

Link copied to clipboard
open override val currentOrNull: T?

The current value T or null being observed

Link copied to clipboard
open val defaultValue: ObservableOptional.Value<T>?

The default ObservableOptional.Value to return if the current value is ObservableOptional.Nothing or ObservableOptional.Value containing null.

Link copied to clipboard
Link copied to clipboard
var observedValue: ObservableOptional<T>

The ObservableOptional or T that is currently being observed.

Link copied to clipboard
var onFirstObservation: () -> Unit?

Action to execute when this observable is observed for the first time.

Link copied to clipboard
open override val stateFlow: MutableStateFlow<T?>

StateFlow that expresses the content from the observable.

Link copied to clipboard
open override val valueDelegate: ReadWriteProperty<Any?, T?>

A ReadOnlyProperty of T

Functions

Link copied to clipboard
open operator override fun getValue(thisRef: Any?, property: KProperty<*>): T?
Link copied to clipboard
open override fun observe(onNext: (T?) -> Unit): Disposable

Adds an observing function to the Observable to be notified on each change to the observable. If there is a current value, there will be an immediate notification

Link copied to clipboard
fun <T> WithState<T?>.observeNotNullOnLifecycle(lifecycleOwner: LifecycleOwner, filter: suspend (T) -> Boolean = { true }, onNext: (T) -> Unit): Job

Observes WithState of a nullable value on the lifecycle of a LifecycleOwner

Link copied to clipboard
fun <T> WithState<T>.observeOnLifecycle(lifecycleOwner: LifecycleOwner, filter: suspend (T) -> Boolean = { true }, onNext: (T) -> Unit): Job

Observes WithState on the lifecycle of a LifecycleOwner

fun <T, R> WithState<T>.observeOnLifecycle(lifecycleOwner: LifecycleOwner, filter: suspend (T) -> Boolean = { true }, transform: suspend (T) -> R, onNext: (R) -> Unit): Job

Observes WithState on the lifecycle of a LifecycleOwner by transforming the observed value.

Link copied to clipboard
suspend fun setValue(value: ObservableOptional<T>): ObservableOptional<T>

set the value of this Observable from a suspended context.

open operator override fun setValue(thisRef: Any?, property: KProperty<*>, value: T?)
Link copied to clipboard
Link copied to clipboard
fun <R : T, T> ReadWriteProperty<Any?, T?>.toDefaultSubject(defaultValue: R, coroutineScope: CoroutineScope? = null, context: CoroutineContext? = coroutineScope?.coroutineContext): ReadWritePropertyDefaultSubject<R, T?>

Converts a ReadWriteProperty to a ReadWritePropertyDefaultSubject

Link copied to clipboard
Link copied to clipboard
fun <T> ReadWriteProperty<Any?, T>.toInitializedSubject(coroutineScope: CoroutineScope? = null, context: CoroutineContext? = coroutineScope?.coroutineContext): ReadWritePropertyInitializedSubject<T>

Converts a ReadWriteProperty to a ReadWritePropertyInitializedSubject