docs: refformated with black

encode · Feb 27, 2024 · 973055d · 973055d
1 parent 07b6c89
commit 973055d
Showing 1 changed file with 10 additions and 3 deletions.
diff --git 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(),