aiq.utils.reactive.subscription#

Attributes#

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

Classes#

Represents a subscription to a Subject.

Module Contents#

_T#

OnNext#

OnError#

OnComplete#

class Subscription( subject: aiq.utils.reactive.base.subject_base.SubjectBase, observer: object | None, )#

Bases: Generic[_T]

Represents a subscription to a Subject. Unsubscribing removes the associated observer from the Subject’s subscriber list.

_subject#

_observer#

_unsubscribed = False#

unsubscribe() → None#: Stop receiving further events.