wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

removing the message queue inside the SmallWebRTCConnection.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-09-26 11:02:17 -03:00
parent ee00ee5c57
commit a5595b82ea
1 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/pipecat/transports/smallwebrtc/connection.py
View File

@@ -283,7 +283,6 @@ class SmallWebRTCConnection(BaseObject):
self._data_channel = None self._data_channel = None
self._renegotiation_in_progress = False self._renegotiation_in_progress = False
self._last_received_time = None self._last_received_time = None
self._message_queue = []
self._pending_app_messages = [] self._pending_app_messages = []
self._connecting_timeout_task = None self._connecting_timeout_task = None
@@ -297,10 +296,7 @@ class SmallWebRTCConnection(BaseObject):
# Flush queued messages once the data channel is open # Flush queued messages once the data channel is open
@channel.on("open") @channel.on("open")
async def on_open(): async def on_open():
logger.debug("Data channel is open, flushing queued messages") logger.debug("Data channel is open!")
while self._message_queue:
message = self._message_queue.pop(0)
self._data_channel.send(message)
@channel.on("message") @channel.on("message")
async def on_message(message): async def on_message(message):
@@ -503,7 +499,6 @@ class SmallWebRTCConnection(BaseObject):
self._track_map.clear() self._track_map.clear()
if self._pc: if self._pc:
await self._pc.close() await self._pc.close()
self._message_queue.clear()
self._pending_app_messages.clear() self._pending_app_messages.clear()
self._track_map = {} self._track_map = {}
self._cancel_monitoring_connecting_state() self._cancel_monitoring_connecting_state()
@@ -669,8 +664,8 @@ class SmallWebRTCConnection(BaseObject):
if self._data_channel and self._data_channel.readyState == "open": if self._data_channel and self._data_channel.readyState == "open":
self._data_channel.send(json_message) self._data_channel.send(json_message)
else: else:
logger.debug("Data channel not ready, queuing message") # The client might choose never to create a data channel.
self._message_queue.append(json_message) logger.trace("Data channel not ready, discarding message!")
def ask_to_renegotiate(self): def ask_to_renegotiate(self):
"""Request renegotiation of the WebRTC connection.""" """Request renegotiation of the WebRTC connection."""