architecture/com.splendo.kaluga.architecture.observable/AbstractBaseUninitializedSubject

AbstractBaseUninitializedSubject

abstract class ~~AbstractBaseUninitializedSubject~~<T>(observation: ObservationUninitialized<T>) : BaseSubject<T, T, ObservableOptional<T>> , UninitializedSubject<T> , MutableUninitialized<T>

Deprecated

This feature has been deprecated. It is recommended to use Compose Multiplatform instead.

An abstract class extending BaseSubject that implements UninitializedSubject.

Parameters

observation

The ObservationUninitialized to handle value being observed

Type Parameters

T

the type of value to expect.

Inheritors

BaseUninitializedSubject

Constructors

AbstractBaseUninitializedSubject

constructor(observation: ObservationUninitialized<T>)

Properties

open override val currentOrNull: T?

The current value T or null being observed

open override val initialValue: ObservableOptional.Nothing<T>

The initial ObservableOptional value of T.

liveDataObserver

val <R : T, T, OO : ObservableOptional<R>> BasicSubject<R, T, OO>.~~liveDataObserver~~: Observer<T>

The Observer that observes the observable value.

open override val stateFlow: MutableStateFlow<T?>

MutableStateFlow that expresses the content from the observable.

open override val valueDelegate: ReadWriteProperty<Any?, T?>

A ReadWriteProperty of T

Functions

override fun bind(coroutineScope: CoroutineScope, context: CoroutineContext)

Bind changes in value to a CoroutineScope in a CoroutineContext

fun <R : T, T, OO : ObservableOptional<R>> BasicSubject<R, T, OO>.~~bind~~(coroutineScope: CoroutineScope)

Convenience method for BasicSubject that calls BasicSubject.bind using the CoroutineContext of the provided CoroutineScope

open operator override fun getValue(thisRef: Any?, property: KProperty<*>): ObservableOptional<T>

open override fun observe(onNext: (T?) -> Unit): Disposable

Creates an observation that calls onNext each time a new value is observed until the resulting Disposable is disposed

observeNotNullOnLifecycle

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

observeOnLifecycle

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.

abstract fun post(newValue: T)

Updates the value of this Postable

abstract suspend fun set(newValue: T)

Updates the value of this Postable in a suspended manner.

toDefaultObservable

fun <R : T, T> ReadOnlyProperty<Any?, T?>.~~toDefaultObservable~~(defaultValue: R): ReadOnlyPropertyDefaultObservable<R, T?>

Converts a ReadOnlyProperty into a ReadOnlyPropertyDefaultObservable

toInitializedObservable

fun <T> ReadOnlyProperty<Any?, T>.~~toInitializedObservable~~(): ReadOnlyPropertyInitializedObservable<T>

Converts a ReadOnlyProperty into a ReadOnlyPropertyInitializedObservable