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

Do a consistency pass on how we're sending UserStartedSpeakingFrames and UserStoppedSpeakingFrames. The codebase is now consistent in broadcasting both types of frames up and downstream.

Browse Source
This commit is contained in:
Paul Kompfner
2026-01-14 18:40:07 -05:00
parent e7b5ff49f4
commit e107902b14
8 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/foundational/22b-natural-conversation-proposal.py
View File

@@ -119,7 +119,7 @@ class CompletenessCheck(FrameProcessor):
if isinstance(frame, TextFrame) and frame.text == "YES":
logger.debug("Completeness check YES")
await self.push_frame(UserStoppedSpeakingFrame())
await self.broadcast_frame(UserStoppedSpeakingFrame)
await self._notifier.notify()
elif isinstance(frame, TextFrame) and frame.text == "NO":
logger.debug("Completeness check NO")

2
examples/foundational/22c-natural-conversation-mixed-llms.py
View File

@@ -322,7 +322,7 @@ class CompletenessCheck(FrameProcessor):
if isinstance(frame, TextFrame) and frame.text == "YES":
logger.debug("!!! Completeness check YES")
await self.push_frame(UserStoppedSpeakingFrame())
await self.broadcast_frame(UserStoppedSpeakingFrame)
await self._notifier.notify()
elif isinstance(frame, TextFrame) and frame.text == "NO":
logger.debug("!!! Completeness check NO")

2
examples/foundational/22d-natural-conversation-gemini-audio.py
View File

@@ -451,7 +451,7 @@ class CompletenessCheck(FrameProcessor):
logger.debug("Completeness check YES")
if self._idle_task:
await self.cancel_task(self._idle_task)
await self.push_frame(UserStoppedSpeakingFrame())
await self.broadcast_frame(UserStoppedSpeakingFrame)
await self._audio_accumulator.reset()
await self._notifier.notify()
elif isinstance(frame, TextFrame):