X=jpSSKJrJrJrJrJr SSKJrJrJ r J r J r J r J r SSKJr \rS/r"SS\5rg))AbstractEventLoop ensure_futureFuture iscoroutinewait)AnyCallablecastDictOptionalSetTuple) EventEmitterAsyncIOEventEmitterc ^\rSrSrSrSS\S\\SS4U4SjjjrS\S\ S \ S \ S\ 4 U4S jjr S\S \ S \\ S 4S \\ \ 4SS4 SjrS\SS4SjrS\SS4Sjr\S\S\ 4Sj5rSrU=r$)r aAn 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. NselfloopreturncT>[[U] 5 Xl[ 5UlgN)superr__init___loopset_waiting)rr __class__s P/Users/stevendouglas/BidBrain/.venv/lib/python3.13/site-packages/pyee/asyncio.pyrAsyncIOEventEmitter.__init__)s !41326 %(U eventargskwargsc,>[TU]"U/UQ70UD6$)a'Emit `event`, passing `*args` and `**kwargs` to each attached function or coroutine. Returns `True` if any functions are attached to `event`; otherwise returns `False`. Example: ```py ee.emit('data', '00101001') ``` Assuming `data` is an attached function, this will call `data('00101001')'`. When executing coroutine handlers, their respective futures will be stored in a "waiting" state. These futures may be waited on or canceled with `wait_for_complete` and `cancel`, respectively; and their status may be checked via the `complete` property. )remit)rr!r"r#rs rr%AsyncIOEventEmitter.emit.s0w|E3D3F33r f.c^U"U0UD6n[U5(aNTR(a#[[[U5TRS9nOA[[[U55nO'[ U[ 5(a[[U5nOgS[ SS4U4SjjnURU5 TRRU5 g![anTRSU5 SnAgSnAff=f)N)rr'rc>TRRU5 UR5(agUR5nU(aTR SU5 gg)Nerror)rdiscard cancelled exceptionr%)r'excrs rcallback/AsyncIOEventEmitter._emit_run..callbackasD %%a(;;==/0{{}IIgs+r r*) rrrr r isinstanceradd_done_callbackradd Exceptionr%)rr'r"r#corofutr/r.s` r _emit_runAsyncIOEventEmitter._emit_runHs  #4*6*D4  :: -T#t_4::NC'S$8CD&))3o ,F ,t ,  ! !( + MM  c "9 $ IIgs # # $sC C3C..C3cn# UR(a[UR5IShvN ggN7f)aWaits for all pending tasks to complete. For example: ```py @ee.on('event') async def async_handler(*args, **kwargs): await returns_a_future() # Triggers execution of async_handler ee.emit('data', '00101001') await ee.wait_for_complete() # async_handler has completed execution ``` This is useful if you're attempting a graceful shutdown of your application and want to ensure all coroutines have completed execution beforehand. N)rrrs rwait_for_complete%AsyncIOEventEmitter.wait_for_completens(( ==t}}% % %  %s *535cURHAnUR5(aMUR5(aM1UR5 MC URR 5 g)aCancel all pending tasks. For example: ```py @ee.on('event') async def async_handler(*args, **kwargs): await returns_a_future() # Triggers execution of async_handler ee.emit('data', '00101001') ee.cancel() # async_handler execution has been canceled ``` This is useful if you're attempting to shut down your application and attempts at a graceful shutdown via `wait_for_complete` have failed. N)rdoner,cancelclear)rr6s rr?AsyncIOEventEmitter.cancelsB&==C88::cmmoo ! r c$UR(+$)aWhen true, there are no pending tasks, and execution is complete. For example: ```py @ee.on('event') async def async_handler(*args, **kwargs): await returns_a_future() # Triggers execution of async_handler ee.emit('data', '00101001') # async_handler is still running, so this prints False print(ee.complete) await ee.wait_for_complete() # async_handler has completed execution, so this prints True print(ee.complete) ``` )rr:s rcompleteAsyncIOEventEmitter.completes,==  r )rrr)__name__ __module__ __qualname____firstlineno____doc__Selfr rrstrrboolr%r rr r7r;r?propertyrC__static_attributes__ __classcell__)rs@rrr s6+t+8,=#>+$++ 4444 4  44$#$# $#CHo$#S#X $#  $#L&d&t&.Td0!t!!!r N)asynciorrrrrtypingrr r r r r r pyee.baserrJ__all__rr rrUs5POBBB"  !f!,f!r