a ݌xd/ @s^ddlmZmZmZmZddlmZmZmZm Z m Z m Z ddl m Z dgZGddde ZdS))AbstractEventLoop ensure_futureFuture iscoroutine)AnyCallablecastDictOptionalTuple) EventEmitterAsyncIOEventEmittercsNeZdZdZd eedfdd Zeee dfe e e fddd Z Z S) r a-An event emitter class which can run asyncio coroutines in addition to synchronous blocking functions. For example:: @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. Nloopcstt|||_dS)N)superr __init___loop)selfr __class__D/var/www/html/Ranjet/env/lib/python3.9/site-packages/pyee/asyncio.pyr%szAsyncIOEventEmitter.__init__.)fargskwargsc sz||i|}Wn0tyB}zd|WYd}~nnd}~00t|rxjrhttt|jd}qttt|}nt|trtt|}ndSfdd}| |dS)Nerrorrcs(|r dS|}|r$d|dS)Nr) cancelled exceptionemit)rexcrrrcallbackAs z/AsyncIOEventEmitter._emit_run..callback) Exceptionrrrrrr isinstanceradd_done_callback)rrrrcororfutr!rr r _emit_run)s"   zAsyncIOEventEmitter._emit_run)N)__name__ __module__ __qualname____doc__r rrrr rr strr' __classcell__rrrrr s   N)asynciorrrrtypingrrrr r r Z pyee.baser __all__r rrrrs