Make unpublish async for future proofing

Author: ladvoc

livekit-rtc/livekit/rtc/data_track.py

@@ -119,7 +119,7 @@ def is_published(self) -> bool:
         resp = FfiClient.instance.request(req)
         return resp.local_data_track_is_published.is_published
 
-    def unpublish(self) -> None:
+    async def unpublish(self) -> None:
         """Unpublishes the track."""
         req = proto_ffi.FfiRequest()
         req.local_data_track_unpublish.track_handle = self._ffi_handle.handle

tests/rtc/test_e2e.py

@@ -499,7 +499,7 @@ async def push_frames():
                 )
                 local_track.try_push(frame)
                 await asyncio.sleep(0.1)
-            local_track.unpublish()
+            await local_track.unpublish()
 
         async def publish_and_receive():
             push_task = asyncio.create_task(push_frames())