g hddlmZmZmZmZddlmZmZmZm Z m Z m Z m Z ddl mZdgZGddeZy))AbstractEventLoop ensure_futureFuture iscoroutine)AnyCallablecastDictOptionalSetTuple) EventEmitterAsyncIOEventEmittercXeZdZdZd deeffd Zdedee dfde e e ffdZ xZ S) ra(An event emitter class which can run asyncio coroutines in addition to synchronous blocking functions. For example: ```py @ee.on('event') async def async_handler(*args, **kwargs): await returns_a_future() ``` On emit, the event emitter will automatically schedule the coroutine using `asyncio.ensure_future` and the configured event loop (defaults to `asyncio.get_event_loop()`). Unlike the case with the EventEmitter, all exceptions raised by event handlers are automatically emitted on the `error` event. This is important for asyncio coroutines specifically but is also handled for synchronous functions for consistency. When `loop` is specified, the supplied event loop will be used when scheduling work with `ensure_future`. Otherwise, the default asyncio event loop is used. For asyncio coroutine event handlers, calling emit is non-blocking. In other words, you do not have to await any results from emit, and the coroutine is scheduled in a fire-and-forget fashion. loopcVtt| ||_t |_yN)superr__init___loopset_waiting)selfr __class__s A/var/www/openai/venv/lib/python3.12/site-packages/pyee/asyncio.pyrzAsyncIOEventEmitter.__init__'s! !41326 %(U fargs.kwargsc ||i|}t|rLjr&ttt|j}n.callbackEsB $$Q';;=!"IIgs+rr") rrrr r isinstanceradd_done_callbackradd Exceptionr&)rrrrcorofutr(r's` r _emit_runzAsyncIOEventEmitter._emit_run,s  #4*6*D4 :: -T#t_4::NC'S$8CD&)3o ,  ! !( + MM  c "9 $ IIgs # # $sB66 C?CCr)__name__ __module__ __qualname____doc__r rrrr rr strr/ __classcell__)rs@rrr sK6+X&78+ $# $#CHo$#S#X $#rN)asynciorrrrtypingrrr r r r r pyee.baser__all__rrrr;s0JIBBB" !E#,E#r