nat.utils.reactive.observable#

Attributes#

`_T_out_co`
`_T`
`OnNext`
`OnError`
`OnComplete`

Classes#

Concrete base Observable that implements subscribe, deferring actual hooking

Module Contents#

_T_out_co#

_T#

OnNext#

OnError#

OnComplete#

class Observable#

Bases: nat.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( observer: nat.utils.reactive.base.observer_base.ObserverBase, ) → nat.utils.reactive.subscription.Subscription#: By default, does nothing. Subclasses should override this to attach the observer to their emission logic.

subscribe( on_next: nat.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, ) → nat.utils.reactive.subscription.Subscription#