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 
57
58
59
60
61
62
63
64
65
66
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