From 33814a79084b5827970dd64c7993c90587bc5ea9 Mon Sep 17 00:00:00 2001 From: Brad P Date: Wed, 24 Dec 2025 05:52:53 -0600 Subject: [PATCH] fix frame accumulation if no publisher --- pytrickle/protocol.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pytrickle/protocol.py b/pytrickle/protocol.py index 2264e51..9a0e063 100644 --- a/pytrickle/protocol.py +++ b/pytrickle/protocol.py @@ -361,7 +361,10 @@ def enqueue_frame(frame: OutputFrame): self.fps_meter.record_egress_video_frame() elif isinstance(frame, AudioOutput): self.fps_meter.record_egress_audio_frame() - + + if self.publish_task is None: + continue + await asyncio.to_thread(enqueue_frame, frame) except Exception as e: logger.error(f"Error in egress loop: {e}")