alchemist-implementationbase/it.unibo.alchemist.model.observables/EventObservable

EventObservable

class EventObservable : AbstractObservable<Unit> (source)

An implementation of Observable that emits updates to its observers when triggered manually via the emit method. The observed value is always Unit. A standard it.unibo.alchemist.model.observation.MutableObservable of Unit is not the answer to an observable emitter, because of observable idempotency.

This class allows multiple observers to register for notifications, and provides the ability to manually emit updates to those observers.

Constructors

EventObservable

constructor()

Properties

current

open override val current: Unit

The current value: while observed, the latest value published; otherwise, a freshly computed one. Observables holding their own state may read it directly.

isObserved

open val isObserved: Boolean

observerCount

override val observerCount: Int

Functions

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

open override fun dispose()

emit

fun emit()

Triggers the emission of a notification from this observable notifying all of its observers.

map

open override fun <S> map(transform: (Unit) -> S): Observable<S>

mergeWith

open override fun <O, R> mergeWith(other: Observable<O>, merge: (Unit, O) -> R): Observable<R>

onChange

open override fun onChange(notifyOnRegistration: Boolean, callback: (Unit) -> Unit): Disposable

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.