o Nh @sbddlmZmZmZmZddlmZmZmZm Z m Z m Z m Z ddl mZdgZGdddeZdS))AbstractEventLoop ensure_futureFuture iscoroutine)AnyCallablecastDictOptionalSetTuple) EventEmitterAsyncIOEventEmittercsReZdZdZd deeffdd Zdedee dfd e e e ffd d Z Z 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. Nloopcs tt|||_t|_dSN)superr__init___loopset_waiting)selfr __class__I/home/air/yokohama/back/venv/lib/python3.10/site-packages/pyee/asyncio.pyr's zAsyncIOEventEmitter.__init__fargs.kwargsc sz ||i|}Wnty"}z d|WYd}~dSd}~wwt|r=jr5ttt|jd}nttt|}n t|trHtt|}ndSfdd}| |j |dS)Nerror)rcs8j||r dS|}|rd|dSdS)Nr)rremove cancelled exceptionemit)rexcrrrcallbackEs z/AsyncIOEventEmitter._emit_run..callback) Exceptionr"rrrrr isinstanceradd_done_callbackradd)rrrrcoror#futr%rr$r _emit_run,s     zAsyncIOEventEmitter._emit_runr)__name__ __module__ __qualname____doc__r rrrr rr strr, __classcell__rrrrr s  N)asynciorrrrtypingrrrr r r r pyee.baser __all__rrrrrs $