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

fix(fastapi_websocket): typo

Browse Source
This commit is contained in:
Kendrick Ha
2025-06-05 13:55:28 +07:00
committed by GitHub
parent 027a82dff1
commit f7761f2b61
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/transports/network/fastapi_websocket.py
View File

@@ -92,7 +92,7 @@ class FastAPIWebsocketClient:
async def trigger_client_connected(self): async def trigger_client_connected(self):
await self._callbacks.on_client_connected(self._websocket) await self._callbacks.on_client_connected(self._websocket)
async def trigger_client_timout(self): async def trigger_client_timeout(self):
await self._callbacks.on_session_timeout(self._websocket) await self._callbacks.on_session_timeout(self._websocket)
def _can_send(self): def _can_send(self):
@@ -188,7 +188,7 @@ class FastAPIWebsocketInputTransport(BaseInputTransport):
async def _monitor_websocket(self): async def _monitor_websocket(self):
"""Wait for self._params.session_timeout seconds, if the websocket is still open, trigger timeout event.""" """Wait for self._params.session_timeout seconds, if the websocket is still open, trigger timeout event."""
await asyncio.sleep(self._params.session_timeout) await asyncio.sleep(self._params.session_timeout)
await self._client.trigger_client_timout() await self._client.trigger_client_timeout()
class FastAPIWebsocketOutputTransport(BaseOutputTransport): class FastAPIWebsocketOutputTransport(BaseOutputTransport):