Skip to content

Commit d7e8852

Browse files
fix frame accumulation if no publisher (#92)
1 parent ae57b62 commit d7e8852

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

pytrickle/protocol.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,7 +361,10 @@ def enqueue_frame(frame: OutputFrame):
361361
self.fps_meter.record_egress_video_frame()
362362
elif isinstance(frame, AudioOutput):
363363
self.fps_meter.record_egress_audio_frame()
364-
364+
365+
if self.publish_task is None:
366+
continue
367+
365368
await asyncio.to_thread(enqueue_frame, frame)
366369
except Exception as e:
367370
logger.error(f"Error in egress loop: {e}")

0 commit comments

Comments
 (0)