class

Observable

const abstract class Observable : Obj

Observable is the subject of an asynchronous data stream.

NOTE: this API is subject to change

 methods onUnsubscribe

Callback after an observer is unsubscribed

 onSubscribe

Callback when new observer is subscribing

 subscriptions

List the active subscriptions

 unsubscribeAll

Unsubscribe all subscriptions

 subscribe

Subscribe an observer actor to this this observables data stream

 unsubscribe

Unsubscribe a current subscription

 hasSubscriptions

Does this observer have any active subscriptions

 name

Return the name of this observable

 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 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 virtual Void onUnsubscribe(Subscription s)

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

 subscribe 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

 Haxall 4.0.5 ∙ 24-Feb-2026 14:33 EST