From b03a7a209c69f028642277b54ec3d86783eeb33c Mon Sep 17 00:00:00 2001 From: Tu Duong Quyet Date: Mon, 26 Feb 2024 08:12:46 +0700 Subject: [PATCH] Fix issue: `publish_track` `unpublish_track` events are not received --- livekit-rtc/livekit/rtc/participant.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/livekit-rtc/livekit/rtc/participant.py b/livekit-rtc/livekit/rtc/participant.py index 377bfbf0..2e325c9b 100644 --- a/livekit-rtc/livekit/rtc/participant.py +++ b/livekit-rtc/livekit/rtc/participant.py @@ -155,7 +155,7 @@ async def publish_track( req.publish_track.local_participant_handle = self._ffi_handle.handle req.publish_track.options.CopyFrom(options) - queue = self._room_queue.subscribe() + queue = FfiClient.instance.queue.subscribe() try: resp = FfiClient.instance.request(req) cb = await queue.wait_for( @@ -173,14 +173,14 @@ async def publish_track( queue.task_done() return track_publication finally: - self._room_queue.unsubscribe(queue) + FfiClient.instance.queue.unsubscribe(queue) async def unpublish_track(self, track_sid: str) -> None: req = proto_ffi.FfiRequest() req.unpublish_track.local_participant_handle = self._ffi_handle.handle req.unpublish_track.track_sid = track_sid - queue = self._room_queue.subscribe() + queue = FfiClient.instance.queue.subscribe() try: resp = FfiClient.instance.request(req) cb = await queue.wait_for( @@ -194,7 +194,7 @@ async def unpublish_track(self, track_sid: str) -> None: publication.track = None queue.task_done() finally: - self._room_queue.unsubscribe(queue) + FfiClient.instance.queue.unsubscribe(queue) class RemoteParticipant(Participant):