Format

Author: ladvoc

livekit-rtc/livekit/rtc/data_track.py

@@ -193,9 +193,7 @@ def publisher_identity(self) -> str:
         """Identity of the participant who published the track."""
         return self._publisher_identity
 
-    async def subscribe(
-        self, *, buffer_size: Optional[int] = None
-    ) -> DataTrackSubscription:
+    async def subscribe(self, *, buffer_size: Optional[int] = None) -> DataTrackSubscription:
         """Subscribes to the data track to receive frames.
 
         Args:
@@ -221,8 +219,7 @@ async def subscribe(
         try:
             resp = FfiClient.instance.request(req)
             cb: proto_ffi.FfiEvent = await queue.wait_for(
-                lambda e: e.subscribe_data_track.async_id
-                == resp.subscribe_data_track.async_id
+                lambda e: e.subscribe_data_track.async_id == resp.subscribe_data_track.async_id
             )
         finally:
             FfiClient.instance.queue.unsubscribe(queue)
@@ -259,9 +256,7 @@ class DataTrackSubscription:
     Dropping or closing the subscription unsubscribes from the track.
     """
 
-    def __init__(
-        self, owned_info: proto_data_track.OwnedDataTrackSubscription
-    ) -> None:
+    def __init__(self, owned_info: proto_data_track.OwnedDataTrackSubscription) -> None:
         self._ffi_handle = FfiHandle(owned_info.handle.id)
         handle_id = owned_info.handle.id
 
@@ -303,9 +298,7 @@ async def __anext__(self) -> DataTrackFrame:
 
     def _send_read_request(self) -> None:
         req = proto_ffi.FfiRequest()
-        req.data_track_subscription_read.subscription_handle = (
-            self._ffi_handle.handle
-        )
+        req.data_track_subscription_read.subscription_handle = self._ffi_handle.handle
         FfiClient.instance.request(req)
 
     def _close(self) -> None:

livekit-rtc/livekit/rtc/participant.py

@@ -704,8 +704,7 @@ async def publish_data_track(
         try:
             resp = FfiClient.instance.request(req)
             cb: proto_ffi.FfiEvent = await queue.wait_for(
-                lambda e: e.publish_data_track.async_id
-                == resp.publish_data_track.async_id
+                lambda e: e.publish_data_track.async_id == resp.publish_data_track.async_id
             )
         finally:
             FfiClient.instance.queue.unsubscribe(queue)