Add flush_audio() to LMNTTTSService

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`.

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():