Skip to content

Commit aa47d36

Browse files
Merge branch 'main' into rf-detr-exp-adapter-fix
2 parents 50c16d4 + f82e457 commit aa47d36

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)