diff --git a/CHANGELOG.md b/CHANGELOG.md index f7c53396a..3464ff274 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,8 +9,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Added -- Added a `flush_audio()` method to `AzureTTSService`, `FishTTSService`, and - `PlayHTTTSService`. +- Added a `flush_audio()` method to `AzureTTSService`, `FishTTSService`, + `PlayHTTTSService`, and `LMNTTTSService`. - Added `set_language()` and `set_model()` to `AzureSTTService`, `AssemblySTTService`, and `GladiaSTTService`. diff --git a/src/pipecat/services/lmnt.py b/src/pipecat/services/lmnt.py index 31ddaf123..cfdf8e6cd 100644 --- a/src/pipecat/services/lmnt.py +++ b/src/pipecat/services/lmnt.py @@ -170,6 +170,11 @@ class LmntTTSService(InterruptibleTTSService): return self._websocket 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): """Receive messages from LMNT websocket.""" async for message in self._get_websocket():