rtvi: fix handling transport messages

2024-09-26 22:42:19 -07:00
parent 2a05cd35b0
commit 6e8a202107
1 changed files with 1 additions and 1 deletions
--- a/src/pipecat/processors/frameworks/rtvi.py
+++ b/src/pipecat/processors/frameworks/rtvi.py
@@ -609,7 +609,7 @@ class RTVIProcessor(FrameProcessor):
            await self._stop(frame)
        # Data frames
        elif isinstance(frame, TransportMessageFrame):
-            await self._message_queue.put(frame)
+            await self._handle_transport_message(frame)
        elif isinstance(frame, RTVIActionFrame):
            await self._action_queue.put(frame)
        # Other frames