format

Author: lukasIO

livekit-rtc/livekit/rtc/data_stream.py

@@ -233,7 +233,9 @@ async def _send_trailer(self, trailer: proto_DataStream.Trailer) -> None:
         if cb.send_stream_chunk.error:
             raise ConnectionError(cb.send_stream_trailer.error)
 
-    async def aclose(self, *, reason: str = "", attributes: Optional[Dict[str, str]] = None) -> None:
+    async def aclose(
+        self, *, reason: str = "", attributes: Optional[Dict[str, str]] = None
+    ) -> None:
         if self._closed:
             raise RuntimeError("Stream already closed")
         self._closed = True