We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2d07fff commit 2b14f8aCopy full SHA for 2b14f8a
1 file changed
getstream/video/rtc/pc.py
@@ -208,14 +208,13 @@ def add_track_subscriber(
208
"""Add a new subscriber to an existing track's MediaRelay."""
209
track_data = self.track_map.get(track_id)
210
211
- blackhole, drain_task, drain_proxy = self._video_drains.pop(
212
- track_id, (None, None, None)
213
- )
+ video_drain = self._video_drains.pop(track_id, None)
214
215
- if blackhole and drain_task and drain_proxy:
+ if video_drain is not None:
+ blackhole, drain_task, drain_proxy = video_drain
216
task = asyncio.create_task(blackhole.stop())
217
drain_proxy.stop()
218
- drain_task.cancel() # safety net if start() becomes long-lived in future aiortc
+ drain_task.cancel()
219
self._background_tasks.add(task)
220
task.add_done_callback(self._background_tasks.discard)
221
0 commit comments