+
    i  c                   s    ^ RI t ^ RIt^ RIt^RIHt ^RIHt ^RIHt ]P                  R8  d   ^ RI	H
t
 M^ RI	Ht
  ! R R4      t ! R	 R
]P                  4      tR# )i    N)eventio
InputEvent)
EvdevErrorSelf)Anyc                   sn   a  ] tR t^t o R tV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR	 ltR
t	V t
R# )ReadIteratorc                s2    \        R4      V n        Wn        R # )N )Zitercurrent_batchdevice)selfr
   s   &&:/usr/lib64/python3.14/site-packages/evdev/eventio_async.py__init__ZReadIterator.__init__   s    !"X    c                    < V ^8  d   QhRS[ /#    returnr   Zformat__classdict__   "r   __annotate__ReadIterator.__annotate__   s      $ r   c                    V # Nr   r      &r   __iter__ZReadIterator.__iter__       r   c                r   r   r   r   r   r   r   r      s     , ,* ,r   c                s    \        V P                  4      #   \         dh    \        P                  ! T P                  P
                  .. . 4      w  rpT P                  P                  4       T n        \        T P                  4      u # i ; ir   )nextr	   StopIterationselectr
   Zfdread)r   ZrZwZxs   &   r   __next__ZReadIterator.__next__   sn    	,**++ 	,mmT[[^^$4b"=GA!!%!1!1!3D**++	,s    A/B	B	c                r   r   r   r   r   r   r   r   #   s      4 r   c                r   r   r   r   r   r   	__aiter__ZReadIterator.__aiter__#   r   r   c                s   < V ^8  d   QhRR/# )r   r   zasyncio.Future[InputEvent]r   r   r   r   r   r   &   s      7 r   c                s  a a \         P                  ! 4       o SP                  \        S P                  4      4       S#   \
         d5    TT 3R  lpS P                  P                  4       P                  T4        S# i ; i)c                 s   <  V P                  4       Sn        SP                  \        SP                  4      4       R #   \         d   pSP                  T4        R p?R # R p?ii ; ir   )Zresultr	   
set_resultr   	Exceptionset_exception)ZbatchZefuturer   s   & r   next_batch_readyZ0ReadIterator.__anext__.<locals>.next_batch_ready-   sP    ,).D&%%d4+=+=&>?  ,((++,s   9> A%	A  A%)	asyncioFuturer$   r   r	   r   r
   
async_readZadd_done_callback)r   r(   r'   s   f @r   	__anext__ZReadIterator.__anext__&   sp    !	Id4#5#567   		I, KK""$667GH		Is   $? ;A>=A>)r	   r
   N)__name__
__module____qualname____firstlineno__r   r   r"   r#   r,   __static_attributes____classdictcell__r      @r   r   r      s2     
 , ,  r   r   c                   sP   a  ] tR t^8t o R tR tR tR tV 3R lR ltR t	Rt
V tR	# )
EventIOc                s   a aa \         P                  ! 4       oVVV 3R  lpSP                  S P                  4       V4       R# )c                  sT   < SP                  SP                  4       4       S ! 4        R # r   )remove_readerfileno)callbackloopr   s   r   readyZ(EventIO._do_when_readable.<locals>.ready<   s    t{{}-Jr   N)r)   get_event_loopZ
add_readerr7   )r   r8   r:   r9   s   ff @r   _do_when_readableZEventIO._do_when_readable9   s,    %%'	 	u-r   c                s     VP                  V! 4       4       R #   \         d   pTP                  T4        R p?R # R p?ii ; ir   )r$   r%   r&   )r   r'   ZcbZerrors   &&& r   _set_resultZEventIO._set_resultB   s8    	(bd# 	(  ''	(s    A<Ac                `   a a \         P                  ! 4       oS P                  VV 3R l4       S# )z|
Asyncio coroutine to read and return a single input event as
an instance of :class:`InputEvent <evdev.events.InputEvent>`.
c                  <   < SP                  S SP                  4      # r   )r=   Zread_oner'   r      r   <lambda>Z(EventIO.async_read_one.<locals>.<lambda>N   s    t'7'7'Nr   r)   r*   r<   r   r'      f@r   async_read_oneZEventIO.async_read_oneH   s%    
 !NOr   c                r>   )z
Asyncio coroutine to read multiple input events from device. Return
a generator object that yields :class:`InputEvent <evdev.events.InputEvent>`
instances.
c                  r?   r   )r=   r!   r@   rA   r   rB   Z$EventIO.async_read.<locals>.<lambda>X   s    t'7'7		'Jr   rC   rD   rE   r   r+   ZEventIO.async_readQ   s%     !JKr   c                r   r   r   r   r   r   r   ZEventIO.__annotate__[   s     " " "r   c                s    \        V 4      # )zj
Return an iterator that yields input events. This iterator is
compatible with the ``async for`` syntax.

rG   r   r   r   async_read_loopZEventIO.async_read_loop[   s     D!!r   c                s     \         P                  ! 4       pVP                  V P                  4       4       R #   \         d     R # i ; ir   )r)   r;   r6   r7   ZRuntimeError)r   r9   s   & r   closeZEventIO.closec   s=    	))+Dt{{}- 	 	s   48 AAr   N)r-   r.   r/   r0   r<   r=   rF   r+   rH   rI   r1   r2   r3   r4   r   r5   r5   8   s-     .(" " r   r5   )i   i   )r)   r    ZsysZ r    Zeventsr   r   Zversion_infoZtypingr   r   r   r5   r   r   r   <module>rJ      sH      
    w"$ $N2goo 2r   