From 973055d15e952b38b2fcfb43b2a2071f91a04c04 Mon Sep 17 00:00:00 2001 From: caiquilipe Date: Mon, 26 Feb 2024 22:33:34 -0300 Subject: [PATCH] docs: refformated with black docs: refformated with black --- broadcaster/_backends/redis.py | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/broadcaster/_backends/redis.py b/broadcaster/_backends/redis.py index 83dd71d..14061cf 100644 --- a/broadcaster/_backends/redis.py +++ b/broadcaster/_backends/redis.py @@ -15,8 +15,13 @@ def __init__(self, url: str): self._port = parsed_url.port or 6379 self._password = parsed_url.password or None self._ssl = parsed_url.scheme == "rediss" - self.kwargs = {"host": self._host, "port": self._port, "password": self._password, "ssl": self._ssl} - + self.kwargs = { + "host": self._host, + "port": self._port, + "password": self._password, + "ssl": self._ssl, + } + self._sub_conn: PubSub | None = None self._pub_conn: PubSub | None = None @@ -40,7 +45,9 @@ async def publish(self, channel: str, message: Any) -> None: async def next_published(self) -> Event: message = None while not message: - message = await self._sub_conn.get_message(ignore_subscribe_messages=True, timeout=None) + message = await self._sub_conn.get_message( + ignore_subscribe_messages=True, timeout=None + ) event = Event( channel=message["channel"].decode(), message=message["data"].decode(),