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

EventNotifier: update docstring with single-consumer use case

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-04-09 16:21:42 -07:00
parent 9d274f0fb3
commit 5f75728207
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/utils/sync/event_notifier.py
View File

@@ -14,9 +14,12 @@ from pipecat.utils.sync.base_notifier import BaseNotifier
class EventNotifier(BaseNotifier): class EventNotifier(BaseNotifier):
"""Event-based notifier using asyncio.Event for task synchronization. """Event-based notifier using asyncio.Event for task synchronization.
Provides a simple notification mechanism where one task can signal Provides a simple single-consumer notification mechanism where one task
an event and other tasks can wait for that event to occur. The event can signal an event and one other task can wait for that event to occur.
is automatically cleared after each wait operation. The event is automatically cleared after each wait operation.
Note: This notifier supports only a single waiter at a time. If multiple
tasks wait concurrently, notifications may be lost.
""" """
def __init__(self): def __init__(self):