i ddlZddlZddlZddlmZddlmZddlmZejdk\rddl m Z nddl m Z Gd d Z Gd d ejZ y) N)eventio) InputEvent) EvdevError) )Self)Anyc>eZdZdZdefdZdefdZdefdZddZ y) ReadIteratorc2td|_||_y)N)iter current_batchdevice)selfrs ]/home/obispo/Crisostomo_bridge/mision_env/lib/python3.12/site-packages/evdev/eventio_async.py__init__zReadIterator.__init__s!"X returnc|SNrrs r__iter__zReadIterator.__iter__ rc t|jS#t$rgtj|jj ggg\}}}|jj |_t|jcYSwxYwr)nextr StopIterationselectrfdread)rrwxs r__next__zReadIterator.__next__sp ,**+ + ,mmT[[^^$4b"=GAq!!%!1!1!3D **+ + ,sA-BBc|Srrrs r __aiter__zReadIterator.__aiter__#rrctj jtjS#t $r3fd}j jj|YSwxYw)Nc |j_jtjy#t$r}j |Yd}~yd}~wwxYwr)resultr set_resultr Exception set_exception)batchefuturers rnext_batch_readyz0ReadIterator.__anext__..next_batch_ready-sP,).D&%%d4+=+=&>? ,((++,s9= A!AA!) asyncioFuturer+rrrr async_readadd_done_callback)rr1r0s` @r __anext__zReadIterator.__anext__&sp! I   d4#5#56 7  I , KK " " $ 6 67G H  Is$>8A:9A:N)rzasyncio.Future[InputEvent]) __name__ __module__ __qualname__rr rrr%r'r6rrrr r s0 $,*,4rr c6eZdZdZdZdZdZdefdZdZ y) EventIOctjfd}jj|y)NcRjjyr) remove_readerfileno)callbacklooprsrreadyz(EventIO._do_when_readable..ready<s   t{{} - Jr)r2get_event_loop add_readerr?)rr@rBrAs`` @r_do_when_readablezEventIO._do_when_readable9s,%%'   u-rc |j|y#t$r}|j|Yd}~yd}~wwxYwr)r+r,r-)rr0cberrors r _set_resultzEventIO._set_resultBs8 (   bd # (   ' ' (s =8=c\tjjfdS)z Asyncio coroutine to read and return a single input event as an instance of :class:`InputEvent `. c<jjSr)rIread_oner0rsrz(EventIO.async_read_one..Nst'7'7 'Nrr2r3rErr0s`@rasync_read_onezEventIO.async_read_oneHs% ! NO rc\tjjfdS)z Asyncio coroutine to read multiple input events from device. Return a generator object that yields :class:`InputEvent ` instances. c<jjSr)rIr!rMsrrNz$EventIO.async_read..Xst'7'7 'JrrOrPs`@rr4zEventIO.async_readQs% ! JK rrct|S)z Return an iterator that yields input events. This iterator is compatible with the ``async for`` syntax. )r rs rasync_read_loopzEventIO.async_read_loop[s D!!rc tj}|j|jy#t$rYywxYwr)r2rCr>r? RuntimeError)rrAs rclosez EventIO.closecs= ))+D   t{{} -   s36 AAN) r7r8r9rErIrQr4r rUrXrrrr;r;8s'.( ""rr;)r2rsysreventsrr version_infotypingr r r r;rrrr^sH  w"$$N2goo2r