alchemist/it.unibo.alchemist.model.observables.util/ObservableLists

ObservableLists

Set of useful extensions on it.unibo.alchemist.model.observation.ObservableList.

Functions

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.

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.

@JvmStatic

@JvmName(name = "flattenMergeObservables")

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

Converts the given ObservableList of observables into a unique observable.

observableListOf

@JvmStatic

fun <T> observableListOf(vararg items: T): ObservableList<T>

Creates a new ObservableList and populates it with the specified items.