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

Merge pull request #1342 from pipecat-ai/mb/lmnt-flush-audio

Browse Source
This commit is contained in:
Mark Backman
2025-03-11 22:22:38 -04:00
committed by GitHub
parent 5860fe5319 5f97f6ff94
commit c196fb5f98
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG.md
View File

@@ -11,7 +11,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- Added support for Chirp voices in `GoogleTTSService`. - Added support for Chirp voices in `GoogleTTSService`.
- Added a `flush_audio()` method to `FishTTSService`. - Added a `flush_audio()` method to `FishTTSService` and `LmntTTSService`.
- Added `on_user_turn_audio_data` and `on_bot_turn_audio_data` to - Added `on_user_turn_audio_data` and `on_bot_turn_audio_data` to
`AudioBufferProcessor`. This gives the ability to grab the audio of only that `AudioBufferProcessor`. This gives the ability to grab the audio of only that

5
src/pipecat/services/lmnt.py
View File

@@ -170,6 +170,11 @@ class LmntTTSService(InterruptibleTTSService):
return self._websocket return self._websocket
raise Exception("Websocket not connected") raise Exception("Websocket not connected")
async def flush_audio(self):
if not self._websocket:
return
await self._get_websocket().send(json.dumps({"flush": True}))
async def _receive_messages(self): async def _receive_messages(self):
"""Receive messages from LMNT websocket.""" """Receive messages from LMNT websocket."""
async for message in self._get_websocket(): async for message in self._get_websocket():