type

Observable

abstract const class Observable : Obj

Observable is the subject of an asynchronous data stream.

NOTE: this API is subject to change

methods

hasSubscriptions	Does this observer have any active subscriptions
name	Return the name of this observable.
onSubscribe	Callback when new observer is subscribing.
onUnsubscribe	Callback after an observer is unsubscribed.
subscribe	Subscribe an observer actor to this this observables data stream
subscriptions	List the active subscriptions
unsubscribe	Unsubscribe a current subscription
unsubscribeAll	Unsubscribe all subscriptions

Slot Details

hasSubscriptions

Bool hasSubscriptions()

Does this observer have any active subscriptions

name

abstract Str name()

Return the name of this observable. This name must match up with the the observe def subtype name

onSubscribe

protected virtual Subscription onSubscribe(Observer observer, Dict config)

Callback when new observer is subscribing. Subclasses can check the config and return their own subscription subclass. This callback can be from any thread, so must be thread safe.

onUnsubscribe

protected virtual Void onUnsubscribe(Subscription s)

Callback after an observer is unsubscribed. This callback can be from any thread, so must be thread safe.

Subscription subscribe(Observer observer, Dict config)

Subscribe an observer actor to this this observables data stream

subscriptions

Subscription[] subscriptions()

List the active subscriptions

unsubscribe

Void unsubscribe(Subscription s)

Unsubscribe a current subscription

unsubscribeAll

Void unsubscribeAll()

Unsubscribe all subscriptions