Skip to content

BrokerState

faststream.nats.broker.state.BrokerState #

BrokerState()
Source code in faststream/nats/broker/state.py 
11
12
13
14
15
def __init__(self) -> None:
    self._connected = False

    self._stream: JetStreamContext | None = None
    self._connection: Client | None = None

connection property #

connection

stream property #

stream

connect #

connect(connection, stream)
Source code in faststream/nats/broker/state.py 
34
35
36
37
def connect(self, connection: "Client", stream: "JetStreamContext") -> None:
    self._connection = connection
    self._stream = stream
    self._connected = True

disconnect #

disconnect()
Source code in faststream/nats/broker/state.py 
39
40
41
42
def disconnect(self) -> None:
    self._connection = None
    self._stream = None
    self._connected = False