transports(base_output): send urgent transport messages immediately

2024-08-15 08:33:36 -07:00
parent 84c5709722
commit 425a730d7c
1 changed files with 2 additions and 0 deletions
--- a/src/pipecat/transports/base_output.py
+++ b/src/pipecat/transports/base_output.py
@@ -151,6 +151,8 @@ class BaseOutputTransport(FrameProcessor):
            await self._handle_audio(frame)
        elif isinstance(frame, ImageRawFrame) or isinstance(frame, SpriteFrame):
            await self._handle_image(frame)
+        elif isinstance(frame, TransportMessageFrame) and frame.urgent:
+            await self.send_message(frame)
        else:
            await self._sink_queue.put(frame)