Skip to content

Commit f82e457

Browse files
Merge pull request #1693 from roboflow/drain-rtsp-queue
Drain rtsp queue
2 parents 22a2afc + 11d8f07 commit f82e457

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)