alchemist/it.unibo.alchemist.model.observation/ObservableList

ObservableList

interface ObservableList<T> : Observable<List<T>>

An observable list whose read-only snapshot is available through current, with observable size.

Inheritors

ObservableMutableList

Properties

current

abstract val current: List<T>

The current state or value of the observable.

isObserved

open val isObserved: Boolean

Whether any callback is currently registered.

observerCount

abstract val observerCount: Int

How many callbacks are currently registered.

size

abstract val size: Observable<Int>

Emits the list size whenever it changes.

Functions

combineLatest

fun <T, R, O> ObservableList<T>.combineLatest(transformer: (T) -> Observable<R>, aggregator: (List<R>) -> O): Observable<O>

Combines the content of an ObservableList into a single observable by applying a mapping function to each element and aggregating the results.

currentOrNull

fun <T> Observable<Option<T>>.currentOrNull(): T?

Retrieves the current value of the observable if present, or null if no value is available.

dispose

abstract override fun dispose()

Unregisters every callback registered with this observable.

flatMap

fun <T, O> ObservableList<T>.flatMap(transformer: (T) -> Observable<O>): Observable<Option<O>>

Transforms an ObservableList of type T into a single Observable of type arrow.core.Option<O> by fusing the individual observables obtained from each item in the list.

flattenMerge

fun <T> ObservableList<out Observable<T>>.flattenMerge(): Observable<Option<T>>

Converts this ObservableList of observables into a unique observable.

map

abstract fun <S> map(transform: (List<T>) -> S): Observable<S>

Transforms the current observable into a new observable by applying the specified transformation function to its emitted values.

mergeWith

abstract fun <O, R> mergeWith(other: Observable<O>, merge: (List<T>, O) -> R): Observable<R>

Combines the current observable with another observable, producing a new observable that emits values derived by applying the provided merge function to the current values of both observables.

onChange

abstract fun onChange(notifyOnRegistration: Boolean = true, callback: (List<T>) -> Unit): Disposable

Registers callback to be invoked with every new value of this observable, and right away with the current one if notifyOnRegistration.

switchMap

@JvmStatic

fun <T, R> Observable<T>.switchMap(transform: (T) -> Observable<R>): Observable<R>

Maps the current value of this Observable to an inner observable through transform, and mirrors the inner observable of the most recent value only: whenever this observable emits, the previous inner observable is unsubscribed and the new one is followed.