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

Add start frame to interrupt loop

Browse Source
This commit is contained in:
Moishe Lettvin
2024-03-06 15:58:19 -05:00
parent d3e76c4fd6
commit 3e46d28aff
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/dailyai/services/base_transport_service.py
View File

@@ -199,12 +199,19 @@ class BaseTransportService():
post_process_task = asyncio.create_task(post_process(post_processor)) post_process_task = asyncio.create_task(post_process(post_processor))
started = False
async for frame in self.get_receive_frames(): async for frame in self.get_receive_frames():
print("Got frame: ", frame.__class__.__name__) print("Got frame: ", frame.__class__.__name__)
if isinstance(frame, UserStartedSpeakingFrame): if isinstance(frame, UserStartedSpeakingFrame):
pipeline_task.cancel() pipeline_task.cancel()
self.interrupt() self.interrupt()
pipeline_task = asyncio.create_task(pipeline.run_pipeline()) pipeline_task = asyncio.create_task(pipeline.run_pipeline())
started = False
continue
if not started:
await self.send_queue.put(StartFrame())
if pre_processor: if pre_processor:
frame_generator = pre_processor.process_frame(frame) frame_generator = pre_processor.process_frame(frame)