From 5f75728207199a09d2a72a58d5640d7670e82729 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 9 Apr 2026 16:21:42 -0700 Subject: [PATCH] EventNotifier: update docstring with single-consumer use case --- src/pipecat/utils/sync/event_notifier.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/pipecat/utils/sync/event_notifier.py b/src/pipecat/utils/sync/event_notifier.py index 65f498852..d55d3fe29 100644 --- a/src/pipecat/utils/sync/event_notifier.py +++ b/src/pipecat/utils/sync/event_notifier.py @@ -14,9 +14,12 @@ from pipecat.utils.sync.base_notifier import BaseNotifier class EventNotifier(BaseNotifier): """Event-based notifier using asyncio.Event for task synchronization. - Provides a simple notification mechanism where one task can signal - an event and other tasks can wait for that event to occur. The event - is automatically cleared after each wait operation. + Provides a simple single-consumer notification mechanism where one task + can signal an event and one other task can wait for that event to occur. + 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):