aiq.utils.reactive.observable#
Attributes#
Classes#
Concrete base Observable that implements subscribe, deferring actual hooking |
Module Contents#
- _T_out_co#
- _T#
- OnNext#
- OnError#
- OnComplete#
- class Observable#
Bases:
aiq.utils.reactive.base.observable_base.ObservableBase[_T_out_co]Concrete base Observable that implements subscribe, deferring actual hooking logic to _subscribe_core.
- abstractmethod _subscribe_core( ) aiq.utils.reactive.subscription.Subscription#
By default, does nothing. Subclasses should override this to attach the observer to their emission logic.
- subscribe(
- on_next: aiq.utils.reactive.base.observer_base.ObserverBase[_T_out_co] | OnNext[_T_out_co] | None = None,
- on_error: OnError | None = None,
- on_complete: OnComplete | None = None,
Subscribes an Observer or callbacks to this Observable.
If an Observer is provided, it will be subscribed to this Observable. If callbacks are provided, they will be wrapped into an Observer and subscribed to this Observable.