AudioBufferProcessor: handle continuous and intermittent user audio

Fixes #1172
This commit is contained in:
Aleix Conchillo Flaqué
2025-02-10 11:25:58 -08:00
parent 32baee924b
commit eb3c9b1e75
4 changed files with 49 additions and 18 deletions

View File

@@ -90,7 +90,7 @@ async def run_bot(websocket_client: WebSocket, stream_sid: str, testing: bool):
# NOTE: Watch out! This will save all the conversation in memory. You can
# pass `buffer_size` to get periodic callbacks.
audiobuffer = AudioBufferProcessor()
audiobuffer = AudioBufferProcessor(user_continuous_stream=not testing)
pipeline = Pipeline(
[

View File

@@ -124,7 +124,7 @@ async def run_client(client_name: str, server_url: str, duration_secs: int):
# NOTE: Watch out! This will save all the conversation in memory. You can
# pass `buffer_size` to get periodic callbacks.
audiobuffer = AudioBufferProcessor()
audiobuffer = AudioBufferProcessor(user_continuous_stream=False)
pipeline = Pipeline(
[