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: Client

stream property #

stream: JetStreamContext

connect #

connect(
    connection: Client, stream: JetStreamContext
) -> None
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() -> None
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