+
    O(i
                         ^ RI t ^ RIt^ RIt^ RIHt ^RIHt ]P                  ]P                  ,          t	]P                  ]P                  ,          t ! R R] P                  4      tR# )    N)partial)abstractc                      a  ] tR t^t o RtRtRtRR ltR tR t	R t
R tR tR	 tR
 tRV 3R lR lltRV 3R lR lltV 3R lR ltV 3R lR ltRtV tR# )AsyncioContextBasei   Nc                    T;'       g    V P                   pT;'       g    \        P                  ! 4       V n        \        P                  ! V4      V n        V P                  ! V3/ VB V n        R # N)MAX_REQUESTS_DEFAULTasyncioget_event_looploopBoundedSemaphore	semaphore_create_contextcontext)selfmax_requestsr   kwargss   &&&,W/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/caio/asyncio_base.py__init__AsyncioContextBase.__init__   sV    #@@t'@'@44G224	 11,?++LCFC    c                *    V P                   ! RR V/VB # )r    )CONTEXT_CLASS)r   r   r   s   &&,r   r   "AsyncioContextBase._create_context   s    !!F|FvFFr   c                    R # r   r   r   s   &r   _destroy_context#AsyncioContextBase._destroy_context   s    r   c                   "   V # 5ir   r   r   s   &r   
__aenter__AsyncioContextBase.__aenter__   s
     s   c                .   "   V P                  4        R # 5ir   )close)r   exc_typeexc_valexc_tbs   &&&&r   	__aexit__AsyncioContextBase.__aexit__!   s     

s   c                &    V P                  4        R # r   )r   r   s   &r   r$   AsyncioContextBase.close$   s    r   c                  "   \        WP                  4      '       g   \        R 4      hV P                  P	                  4       pVP                  \        V P                  V4      4       V P                  ;_uu_4       GRj  xL
  V P                  P                  V4      ^8w  d   \        R4      h VG Rj  xL
  TP                  4       uuRRR4      GRj  xL
  #  L\ L(  \        P                   d0     T P                  P                  T4       h   \         d     h i ; ii ; i LP  + GRj  xL 
 '       g   i     R# ; i5i)zOperation object expectedNzOperation was not submitted)
isinstanceOPERATION_CLASS
ValueErrorr   create_futureset_callbackr   _on_doner   r   submitIOErrorr
   CancelledErrorcancel	get_value)r   opfutures   && r   r3   AsyncioContextBase.submit'   s     "2233899((*
v67>>>>||""2&!+;<< <<> ">>
 )) LL''+  "  ">>>s   A>E CE,D*1C!6C7C!;D*
ED(EC!!D%7DD%D!	D% D!	!D%%D*(E*E	0D31
E	<E	>	Ec                v   a SP                  4       '       d   R# V P                  P                  V3R l4       R# )z
In general case impossible predict current thread and the thread
of event loop. So have to use `call_soon_threadsave` the result setter.
Nc                  V   < S P                  4       ;'       g    S P                  R 4      # )T)done
set_result)r9   s   r   <lambda>-AsyncioContextBase._on_done.<locals>.<lambda>F   s!    FKKM<<V%6%6t%<<r   )r=   r   call_soon_threadsafe)r   r9   results   &f&r   r2   AsyncioContextBase._on_done<   s(     ;;==		&&<	
r   c                \   < V ^8  d   QhRS[ RS[ RS[ RS[ RS[P                  S[,          /# )   nbytesfdoffsetpriorityreturn)inttyping	Awaitablebytes)format__classdict__s   "r   __annotate__AsyncioContextBase.__annotate__I   sB     
 

"

"
 
		%	 
r   c                X    V P                  V P                  P                  WW44      4      # r   )r3   r.   read)r   rF   rG   rH   rI   s   &&&&&r   rT   AsyncioContextBase.readI   s+     {{  %%f&C
 	
r   c                \   < V ^8  d   QhRS[ RS[RS[RS[RS[P                  S[,          /# )rE   payloadrG   rH   rI   rJ   )rN   rK   rL   rM   )rO   rP   s   "r   rQ   rR   Q   sB     
 

"%

"
 
		#	
r   c                X    V P                  V P                  P                  WW44      4      # r   )r3   r.   write)r   rW   rG   rH   rI   s   &&&&&r   rY   AsyncioContextBase.writeQ   s+     {{  &&wFE
 	
r   c                :   < V ^8  d   QhRS[ RS[P                  /# rE   rG   rJ   rK   rL   rM   )rO   rP   s   "r   rQ   rR   Y   s!     ; ; ; 0 0 ;r   c                V    V P                  V P                  P                  V4      4      # r   )r3   r.   fsyncr   rG   s   &&r   r_   AsyncioContextBase.fsyncY   s"    {{4//55b9::r   c                :   < V ^8  d   QhRS[ RS[P                  /# r\   r]   )rO   rP   s   "r   rQ   rR   \   s!     < < <!1!1 <r   c                V    V P                  V P                  P                  V4      4      # r   )r3   r.   fdsyncr`   s   &&r   rd   AsyncioContextBase.fdsync\   s"    {{4//66r:;;r   )r   r   r   )NN)r   )__name__
__module____qualname____firstlineno__r	   r   r.   r   r   r   r!   r(   r$   r3   r2   rT   rY   r_   rd   __static_attributes____classdictcell__)rP   s   @r   r   r      sg     MODG "*

 

 
; ;< <r   r   )abcr
   rL   	functoolsr    r   TypeAbstractContextContextTypeAbstractOperationOperationTypeABCr   r   r   r   <module>ru      sP    
     kk(223H667P< P<r   