Skip to content

ConnectedSubscriberState

faststream.nats.subscriber.state.ConnectedSubscriberState #

ConnectedSubscriberState(
    *,
    parent_state: BrokerState,
    kv_declarer: KVBucketDeclarer,
    os_declarer: OSBucketDeclarer,
)

Bases: SubscriberState

Source code in faststream/nats/subscriber/state.py 
67
68
69
70
71
72
73
74
75
76
def __init__(
    self,
    *,
    parent_state: "BrokerState",
    kv_declarer: "KVBucketDeclarer",
    os_declarer: "OSBucketDeclarer",
) -> None:
    self._parent_state = parent_state
    self.kv_declarer = kv_declarer
    self.os_declarer = os_declarer

kv_declarer instance-attribute #

kv_declarer = kv_declarer

os_declarer instance-attribute #

os_declarer = os_declarer

client property #

client: Client

js property #

js: JetStreamContext