Source code for pipecat.sync.event_notifier

#
# Copyright (c) 2024–2025, Daily
#
# SPDX-License-Identifier: BSD 2-Clause License
#

import asyncio

from pipecat.sync.base_notifier import BaseNotifier



[docs]
class EventNotifier(BaseNotifier):
    def __init__(self):
        self._event = asyncio.Event()


[docs]
    async def notify(self):
        self._event.set()



[docs]
    async def wait(self):
        await self._event.wait()
        self._event.clear()