Skip to content

ConnectionState

faststream.redis.configs.state.ConnectionState #

ConnectionState(options: dict[str, Any] | None = None)

Bases: ABC, Generic[ClientT]

Base connection state.

Source code in faststream/redis/configs/state.py 
24
25
26
27
28
29
30
def __init__(self, options: dict[str, Any] | None = None) -> None:
    self._options = options or {}

    self._connected = False
    self._client: ClientT | None = None
    self._sync_cluster: Any = None
    self._thread_pool: Any = None

client property #

client: ClientT

connect abstractmethod async #

connect() -> ClientT
Source code in faststream/redis/configs/state.py 
43
44
@abstractmethod
async def connect(self) -> ClientT: ...

disconnect async #

disconnect() -> None
Source code in faststream/redis/configs/state.py 
46
47
48
49
50
51
async def disconnect(self) -> None:
    if self._client:
        await self._client.aclose()  # type: ignore[attr-defined]

    self._client = None
    self._connected = False