alchemist/it.unibo.alchemist.model.observables.util/ObservableSets/flattenMerge

flattenMerge

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

Converts this ObservableSet of observables into a unique observable that emits when either this set would have changed (addition/removal of members) or one of its members emits a value.

The resulting observable is safe on empty sets: it emits arrow.core.None when the set is empty.

Return

a unique observable wrapping in one place all the notifications emitted by this ObservableSet

@JvmStatic

@JvmName(name = "flattenMergeObservables")

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

Converts the given ObservableSet of observables into a unique observable that emits when either this set would have changed (addition/removal of members) or one of its members emits a value.

The resulting observable is safe on empty sets: it emits arrow.core.None when the set is empty.

Return

a unique observable wrapping in one place all the notifications emitted by this ObservableSet