aiq.utils.reactive.observer

Attributes

logger
_T_in_contra
_T
OnNext
OnError
OnComplete

Classes

Observer

Concrete Observer that wraps user-provided callbacks into an ObserverBase.

Module Contents

logger

_T_in_contra

_T

OnNext

OnError

OnComplete

class Observer(

on_next: OnNext | None = None,

on_error: OnError | None = None,

on_complete: OnComplete | None = None,

)

Bases: aiq.utils.reactive.base.observer_base.ObserverBase[_T_in_contra]

Concrete Observer that wraps user-provided callbacks into an ObserverBase.

_on_next = None

_on_error = None

_on_complete = None

_stopped = False

on_next(value: _T) → None

Called when a new item is produced. If the observer is stopped, this call should be ignored or raise an error.

on_error(exc: Exception) → None

Called when the producer signals an unrecoverable error. After this call, the observer is stopped.

on_complete() → None

Called when the producer signals completion (no more items). After this call, the observer is stopped.