Skip to content

Commit 11d8f07

Browse files
Drain rtsp queue
1 parent 22a2afc commit 11d8f07

File tree

1 file changed

+1
-1
lines changed
  • inference/core/interfaces/webrtc_worker

1 file changed

+1
-1
lines changed

inference/core/interfaces/webrtc_worker/webrtc.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ async def recv(self):
131131
self._terminate_event.set()
132132

133133
if isinstance(self.track, PlayerStreamTrack):
134-
if self.track._queue.qsize() > 30:
134+
while self.track._queue.qsize() > 30:
135135
self.track._queue.get_nowait()
136136
frame: VideoFrame = await self.track.recv()
137137

0 commit comments

Comments
 (0)