architecture/com.splendo.kaluga.architecture.observable/BaseDefaultSubject

BaseDefaultSubject

actual abstract class BaseDefaultSubject<R : T?, T>(observation: ObservationDefault<R, T?>) : AbstractBaseDefaultSubject<R, T>

An abstract class extending AbstractBaseDefaultSubject.

Parameters

T

the type of value to expect.

R

the type of result to expect. Must be a subclass of T

observation

The ObservationUninitialized to handle value being observed

expect abstract class BaseDefaultSubject<R : T?, T>(observation: ObservationDefault<R, T?>) : AbstractBaseDefaultSubject<R, T>

An abstract class extending AbstractBaseDefaultSubject.

Parameters

T

the type of value to expect.

R

the type of result to expect. Must be a subclass of T

observation

The ObservationUninitialized to handle value being observed

Inheritors

StateFlowDefaultSubject

SharedFlowDefaultSubject

ReadWritePropertyDefaultSubject

SimpleDefaultSubject

actual abstract class BaseDefaultSubject<R : T?, T>

An abstract class extending AbstractBaseDefaultSubject.

Parameters

T

the type of value to expect.

R

the type of result to expect. Must be a subclass of T

observation

The ObservationUninitialized to handle value being observed

actual abstract class BaseDefaultSubject<R : T?, T>(observation: ObservationDefault<R, T?>) : AbstractBaseDefaultSubject<R, T>

An abstract class extending AbstractBaseDefaultSubject.

Parameters

T

the type of value to expect.

R

the type of result to expect. Must be a subclass of T

observation

The ObservationUninitialized to handle value being observed

actual abstract class BaseDefaultSubject<R : T?, T>(observation: ObservationDefault<R, T?>) : AbstractBaseDefaultSubject<R, T>

An abstract class extending AbstractBaseDefaultSubject.

Parameters

T

the type of value to expect.

R

the type of result to expect. Must be a subclass of T

observation

The ObservationUninitialized to handle value being observed

Constructors

BaseDefaultSubject

actual constructor(defaultValue: ObservableOptional.Value<R>, initialValue: ObservableOptional.Value<T?>)

Constructor

actual constructor(observation: ObservationDefault<R, T?>)

expect constructor(defaultValue: ObservableOptional.Value<R>, initialValue: ObservableOptional.Value<T?>)

Constructor

expect constructor(observation: ObservationDefault<R, T?>)

actual constructor(defaultValue: ObservableOptional.Value<R>, initialValue: ObservableOptional.Value<T?>)

Constructor

actual constructor(observation: ObservationDefault<R, T?>)

actual constructor(defaultValue: ObservableOptional.Value<R>, initialValue: ObservableOptional.Value<T?>)

Constructor

actual constructor(observation: ObservationDefault<R, T?>)

Properties

open override val current: R

The current value of R

open override val current: R

The current value of R

open override val current: R

The current value of R

open override val current: R

The current value of R

open override val currentOrNull: T?

The current value T or null being observed

open override val currentOrNull: T?

The current value T or null being observed

open override val currentOrNull: T?

The current value T or null being observed

open override val currentOrNull: T?

The current value T or null being observed

open override val defaultValue: ObservableOptional.Value<R>

The default Value of R. Can be used in case Nothing is Initial.initialValue

open override val defaultValue: ObservableOptional.Value<R>

The default Value of R. Can be used in case Nothing is Initial.initialValue

open override val defaultValue: ObservableOptional.Value<R>

The default Value of R. Can be used in case Nothing is Initial.initialValue

open override val defaultValue: ObservableOptional.Value<R>

The default Value of R. Can be used in case Nothing is Initial.initialValue

open override val initialValue: ObservableOptional.Value<T?>

The initial ObservableOptional value of T.

open override val initialValue: ObservableOptional.Value<T?>

The initial ObservableOptional value of T.

open override val initialValue: ObservableOptional.Value<T?>

The initial ObservableOptional value of T.

open override val initialValue: ObservableOptional.Value<T?>

The initial ObservableOptional value of T.

open override val liveData: LiveData<R>

The LiveData matching stateFlow

liveDataObserver

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

The Observer that observes the observable value.

mutableLiveData

val mutableLiveData: MutableLiveData<R>

The MutableLiveData synchronizing the value of the subject.

open override val stateFlow: MutableStateFlow<R>

StateFlow that expresses the content from the observable.

open override val stateFlow: MutableStateFlow<R>

StateFlow that expresses the content from the observable.

open override val stateFlow: MutableStateFlow<R>

StateFlow that expresses the content from the observable.

open override val stateFlow: MutableStateFlow<R>

StateFlow that expresses the content from the observable.

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

A ReadOnlyProperty of T

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

A ReadOnlyProperty of T

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

A ReadOnlyProperty of T

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

A ReadOnlyProperty of T

Functions

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

Bind changes in value to a CoroutineScope in a CoroutineContext

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

Bind changes in value to a CoroutineScope in a CoroutineContext

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

Bind changes in value to a CoroutineScope in a CoroutineContext

actual 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.Value<R>

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

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

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

liveDataObserver

fun liveDataObserver(): Observer<R>

Gets an Observer to observe changes to this subject.

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

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

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

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

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

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

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

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

observeInitialized

open override fun observeInitialized(onNext: (R) -> Unit): Disposable

open override fun observeInitialized(onNext: (R) -> Unit): Disposable

open override fun observeInitialized(onNext: (R) -> Unit): Disposable

open override fun observeInitialized(onNext: (R) -> Unit): Disposable

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 fun post(newValue: T?)

Updates the value of this Postable

abstract fun post(newValue: T?)

Updates the value of this Postable

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.

abstract suspend fun set(newValue: T?)

Updates the value of this Postable in a suspended manner.

abstract suspend fun set(newValue: T?)

Updates the value of this Postable in a suspended manner.

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