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

Fix example 2

Browse Source
This commit is contained in:
Moishe Lettvin
2024-03-11 13:00:29 -04:00
parent de026ccc8a
commit fd2fa23e9c
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/examples/foundational/02-llm-say-one-thing.py
View File

@@ -42,15 +42,21 @@ async def main(room_url):
} }
] ]
@transport.event_handler("on_first_other_participant_joined") other_joined_event = asyncio.Event()
async def on_first_other_participant_joined(transport): async def speak_from_llm():
await other_joined_event.wait()
await tts.run_to_queue( await tts.run_to_queue(
transport.send_queue, transport.send_queue,
llm.run([LLMMessagesQueueFrame(messages)]), llm.run([LLMMessagesQueueFrame(messages)]),
add_end_of_stream=True
) )
await transport.stop_when_done() await transport.stop_when_done()
await transport.run() @transport.event_handler("on_first_other_participant_joined")
async def on_first_other_participant_joined(transport):
other_joined_event.set()
await asyncio.gather(transport.run(), speak_from_llm())
if __name__ == "__main__": if __name__ == "__main__":