+
    Di)                      a  0 t $ ^ RIHt ^ RIt^ RIt^ RIHtHt ^ RIH	t	H
t
HtHt ^ RIHt ^ RIHt ^ RIHt ^ RIHtHtHt ^ R	IHtHtHtHtHtHt ]P:                  R8  d
   ^ R
IHtHt M^ R
I HtHt ]P:                  R8  d   ^ RIH!t! M^ RI H!t! ]'       dE   ^ RI"H#t# ^RI$H%t%H&t&H't'H(t( ^RI)H*t* ^RI+H,t, ^RI-H.t.H/t/H0t0H1t1H2t2H3t3H4t4H5t5 ^RI6H7t7 ^RI8H9t9 ^RI:H;t; ]! R4      t<]! R4      t=]]>]?RR3,          t@R]AR&    ! R R]R7      tBR# )    )annotationsN)ABCMetaabstractmethod)AsyncIterator	AwaitableCallableSequence)AbstractContextManager)PathLike)Signals)AddressFamily
SocketKindsocket)IOTYPE_CHECKINGAnyTypeVarUnionoverload)TypeVarTupleUnpack)	TypeAlias)FileDescriptorLike)CapacityLimiterEventLock	Semaphore)CancelScope)TaskInfo)ConnectedUDPSocketConnectedUNIXDatagramSocketIPSockAddrTypeSocketListenerSocketStream	UDPSocketUNIXDatagramSocketUNIXSocketStream)Process)	TaskGroup)
TestRunnerT_RetvalPosArgsTzPathLike[str]zPathLike[bytes]r   StrOrBytesPathc            
      .   ] tR t^7t]]R R l4       4       t]]R R l4       4       t]]R R l4       4       t]]R R l4       4       t	]]R	 R
 l4       4       t
]R R l4       t]R R l4       t]]R R l4       4       t]]R]P                  RR/R R ll4       4       t]]R R l4       4       t]]R R l4       4       t]]R R l4       4       t]]R R l4       4       t]]RRR R/R! R" ll4       4       t]]R# R$ l4       4       t]]RjR% R& ll4       4       t]]R' R( l4       4       t]]R) R* l4       4       t]]R+ R, l4       4       t]]R- R. l4       4       t]]R/ R0 l4       4       t]]RkR1 R2 ll4       4       t]]R3 R4 l4       4       t]]R5 R6 l4       4       t]]R7 R8 l4       4       t ]]R9 R: l4       4       t!]]"R; R< l4       4       t#]]"R= R> l4       4       t#]]R? R@ l4       4       t#]]RA^ RB^ RC^ RD^ /RE RF ll4       4       t$]]RlRG RH ll4       4       t%]]RI RJ l4       4       t&]]RK RL l4       4       t']]RM RN l4       4       t(]]RO RP l4       4       t)]]RQ RR l4       4       t*]]RS RT l4       4       t+]]RU RV l4       4       t,]]RW RX l4       4       t-]]RY RZ l4       4       t.]]R[ R\ l4       4       t/]]R] R^ l4       4       t0]]R_ R` l4       4       t1]]Ra Rb l4       4       t2]]Rc Rd l4       4       t3]]Re Rf l4       4       t4]]Rg Rh l4       4       t5Rit6R# )mAsyncBackendc          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
   func1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]argstuple[Unpack[PosArgsT]]kwargsdict[str, Any]optionsreturnr+    )formats   "r/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/anyio/abc/_eventloop.py__annotate__AsyncBackend.__annotate__:   s<      ? & 	
   
    c                    R# )a  
Run the given coroutine function in an asynchronous event loop.

The current thread must not be already running an event loop.

:param func: a coroutine function
:param args: positional arguments to ``func``
:param kwargs: positional arguments to ``func``
:param options: keyword arguments to call the backend ``run()`` implementation
    with
:return: the return value of the coroutine function
Nr:   )clsr2   r4   r6   r8   s   &&&&&r<   runAsyncBackend.run8       r?   c                   V ^8  d   QhRR/# )r1   r9   objectr:   )r;   s   "r<   r=   r>   P   s      f r?   c                    R# )z
Return an object that allows other threads to run code inside the event loop.

:return: a token object, specific to the event loop running in the current
    thread
Nr:   rA   s   &r<   current_tokenAsyncBackend.current_tokenN   rD   r?   c                   V ^8  d   QhRR/# r1   r9   floatr:   )r;   s   "r<   r=   r>   Z   s      U r?   c                    R# )zb
Return the current value of the event loop's internal clock.

:return: the clock value (seconds)
Nr:   rH   s   &r<   current_timeAsyncBackend.current_timeX   rD   r?   c                   V ^8  d   QhRR/# )r1   r9   ztype[BaseException]r:   )r;   s   "r<   r=   r>   c   s     U U*= Ur?   c                    R# )zFReturn the exception class that is raised in a task if it's cancelled.Nr:   rH   s   &r<   cancelled_exception_class&AsyncBackend.cancelled_exception_classa   rD   r?   c                   V ^8  d   QhRR/# r1   r9   Noner:   )r;   s   "r<   r=   r>   h   s       r?   c                   "   R# 5i)z
Check if the task has been cancelled, and allow rescheduling of other tasks.

This is effectively the same as running :meth:`checkpoint_if_cancelled` and then
:meth:`cancel_shielded_checkpoint`.
Nr:   rH   s   &r<   
checkpointAsyncBackend.checkpointf           c                   V ^8  d   QhRR/# rV   r:   )r;   s   "r<   r=   r>   q   s     	# 	#d 	#r?   c                   "   V P                  4       \        P                  ) 8X  d   V P                  4       G Rj  xL
  R# R#  L5i)z
Check if the current task group has been cancelled.

This will check if the task has been cancelled, but will not allow other tasks
to be scheduled if not.

N)current_effective_deadlinemathinfrY   rH   s   &r<   checkpoint_if_cancelled$AsyncBackend.checkpoint_if_cancelledp   s6      ))+y8..""" 9"s   8AA	Ac                   V ^8  d   QhRR/# rV   r:   )r;   s   "r<   r=   r>   }   s     	 	 	r?   c                   "   V P                  RR7      ;_uu_ 4        V P                  ^ 4      G Rj  xL
  RRR4       R#  L  + '       g   i     R# ; i5i)z
Allow the rescheduling of other tasks.

This will give other tasks the opportunity to run, but without checking if the
current task group has been cancelled, unlike with :meth:`checkpoint`.

T)shieldN)create_cancel_scopesleeprH   s   &r<   cancel_shielded_checkpoint'AsyncBackend.cancel_shielded_checkpoint|   sB      $$D$11))A, 21 211s+   AAAA
AAA		Ac                    V ^8  d   QhRRRR/# )r1   delayrM   r9   rW   r:   )r;   s   "r<   r=   r>      s       $ r?   c                   "   R# 5i)z\
Pause the current task for the specified duration.

:param delay: the duration, in seconds
Nr:   )rA   rl   s   &&r<   rh   AsyncBackend.sleep   r[   r\   deadlinerf   Fc               $    V ^8  d   QhRRRRRR/# )r1   ro   rM   rf   boolr9   r   r:   )r;   s   "r<   r=   r>      s$      48	r?   c               	    R # Nr:   )rA   ro   rf   s   &$$r<   rg    AsyncBackend.create_cancel_scope       
 	r?   c                   V ^8  d   QhRR/# rL   r:   )r;   s   "r<   r=   r>      s     
 
5 
r?   c                    R# )a  
Return the nearest deadline among all the cancel scopes effective for the
current task.

:return:
    - a clock value from the event loop's internal clock
    - ``inf`` if there is no deadline in effect
    - ``-inf`` if the current scope has been cancelled
:rtype: float
Nr:   rH   s   &r<   r_   'AsyncBackend.current_effective_deadline   rD   r?   c                   V ^8  d   QhRR/# )r1   r9   r)   r:   )r;   s   "r<   r=   r>      s      ) r?   c                	    R # rs   r:   rH   s   &r<   create_task_groupAsyncBackend.create_task_group        	r?   c                   V ^8  d   QhRR/# )r1   r9   r   r:   )r;   s   "r<   r=   r>      s      U r?   c                	    R # rs   r:   rH   s   &r<   create_eventAsyncBackend.create_event   r}   r?   c                    V ^8  d   QhRRRR/# )r1   fast_acquirerq   r9   r   r:   )r;   s   "r<   r=   r>      s      $ 4 r?   c               	    R # rs   r:   )rA   r   s   &$r<   create_lockAsyncBackend.create_lock   r}   r?   	max_valueNr   c               (    V ^8  d   QhRRRRRRRR/# )	r1   initial_valueintr   z
int | Noner   rq   r9   r   r:   )r;   s   "r<   r=   r>      s2       	
  
r?   c               	    R # rs   r:   )rA   r   r   r   s   &&$$r<   create_semaphoreAsyncBackend.create_semaphore   s     	r?   c                    V ^8  d   QhRRRR/# )r1   total_tokensrM   r9   r   r:   )r;   s   "r<   r=   r>      s      5 _ r?   c                	    R # rs   r:   )rA   r   s   &&r<   create_capacity_limiter$AsyncBackend.create_capacity_limiter   r}   r?   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r1   r2   &Callable[[Unpack[PosArgsT]], T_Retval]r4   r5   abandon_on_cancelrq   limiterzCapacityLimiter | Noner9   r+   r:   )r;   s   "r<   r=   r>      s<      4 &  	
 ( 
r?   c                	   "   R # 5irs   r:   )rA   r2   r4   r   r   s   &&&&&r<   run_sync_in_worker_thread&AsyncBackend.run_sync_in_worker_thread   
      	r\   c                   V ^8  d   QhRR/# rV   r:   )r;   s   "r<   r=   r>      s       r?   c                	    R # rs   r:   rH   s   &r<   check_cancelledAsyncBackend.check_cancelled   r}   r?   c               (    V ^8  d   QhRRRRRRRR/# )	r1   r2   r3   r4   r5   tokenrF   r9   r+   r:   )r;   s   "r<   r=   r>      s2      ? & 	
 
r?   c                	    R # rs   r:   rA   r2   r4   r   s   &&&&r<   run_async_from_thread"AsyncBackend.run_async_from_thread        	r?   c               (    V ^8  d   QhRRRRRRRR/# )	r1   r2   r   r4   r5   r   rF   r9   r+   r:   )r;   s   "r<   r=   r>      s2      4 & 	
 
r?   c                	    R # rs   r:   r   s   &&&&r<   run_sync_from_thread!AsyncBackend.run_sync_from_thread   r   r?   c               0    V ^8  d   QhRRRRRRRRRRR	R
/# )r1   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]stdinzint | IO[Any] | Nonestdoutstderrr6   r   r9   r(   r:   )r;   s   "r<   r=   r>      sF     	 	:	 $		
 %	 %	 	 
	r?   c               	   "   R # 5irs   r:   )rA   r   r   r   r   r6   s   &&$$$,r<   open_processAsyncBackend.open_process   s
      	r\   c                    V ^8  d   QhRRRR/# )r1   workerszset[Process]r9   rW   r:   )r;   s   "r<   r=   r>      s      , 4 r?   c                	    R # rs   r:   )rA   r   s   &&r<   #setup_process_pool_exit_at_shutdown0AsyncBackend.setup_process_pool_exit_at_shutdown   r}   r?   c               (    V ^8  d   QhRRRRRRRR/# )	r1   hoststrportr   local_addressIPSockAddrType | Noner9   r$   r:   )r;   s   "r<   r=   r>      s,      !2G	r?   c                	   "   R # 5irs   r:   )rA   r   r   r   s   &&&&r<   connect_tcpAsyncBackend.connect_tcp   
     
 	r\   c                    V ^8  d   QhRRRR/# )r1   pathstr | bytesr9   r'   r:   )r;   s   "r<   r=   r>     s      k 6F r?   c                	   "   R # 5irs   r:   )rA   r   s   &&r<   connect_unixAsyncBackend.connect_unix  
      	r\   c                    V ^8  d   QhRRRR/# r1   sockr   r9   r#   r:   )r;   s   "r<   r=   r>   	  s      v . r?   c                	    R # rs   r:   rA   r   s   &&r<   create_tcp_listener AsyncBackend.create_tcp_listener  r}   r?   c                    V ^8  d   QhRRRR/# r   r:   )r;   s   "r<   r=   r>     s       > r?   c                	    R # rs   r:   r   s   &&r<   create_unix_listener!AsyncBackend.create_unix_listener  r}   r?   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r1   familyr   r   r   remote_address
reuse_portrq   r9   zUDPSocket | ConnectedUDPSocketr:   )r;   s   "r<   r=   r>     s<       - .	
  
(r?   c                	   "   R # 5irs   r:   )rA   r   r   r   r   s   &&&&&r<   create_udp_socketAsyncBackend.create_udp_socket  r   r\   c               $    V ^8  d   QhRRRRRR/# )r1   
raw_socketr   remote_pathrW   r9   r&   r:   )r;   s   "r<   r=   r>     s$     ! !!.2!	!r?   c                	   "   R # 5irs   r:   rA   r   r   s   &&&r<   create_unix_datagram_socket(AsyncBackend.create_unix_datagram_socket  s
      !r\   c               $    V ^8  d   QhRRRRRR/# )r1   r   r   r   r   r9   r!   r:   )r;   s   "r<   r=   r>   $  s$     * **.9*	$*r?   c                	   "   R # 5irs   r:   r   s   &&&r<   r   r   "  s
      '*r\   c               $    V ^8  d   QhRRRRRR/# )r1   r   r   r   zstr | bytes | Noner9   z0UNIXDatagramSocket | ConnectedUNIXDatagramSocketr:   )r;   s   "r<   r=   r>   *  s$      .@	9r?   c                	   "   R # 5irs   r:   r   s   &&&r<   r   r   (  r   r\   r   typeprotoflagsc               4    V ^8  d   QhRRRRRRRRR	R
RR
RR/# )r1   r   zbytes | str | Noner   zstr | int | Noner   zint | AddressFamilyr   zint | SocketKindr   r   r   r9   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]r:   )r;   s   "r<   r=   r>   1  sP        
 $   
r?   c               	   "   R # 5irs   r:   )rA   r   r   r   r   r   r   s   &&&$$$$r<   getaddrinfoAsyncBackend.getaddrinfo/  s
     ( 	r\   c               $    V ^8  d   QhRRRRRR/# )r1   sockaddrr"   r   r   r9   ztuple[str, str]r:   )r;   s   "r<   r=   r>   G  s$      %.1	r?   c                	   "   R # 5irs   r:   )rA   r   r   s   &&&r<   getnameinfoAsyncBackend.getnameinfoE  r   r\   c                    V ^8  d   QhRRRR/# r1   objr   r9   rW   r:   )r;   s   "r<   r=   r>   N        &8 T r?   c                	   "   R # 5irs   r:   rA   r   s   &&r<   wait_readableAsyncBackend.wait_readableL  r   r\   c                    V ^8  d   QhRRRR/# r   r:   )r;   s   "r<   r=   r>   S  r   r?   c                	   "   R # 5irs   r:   r   s   &&r<   wait_writableAsyncBackend.wait_writableQ  r   r\   c                    V ^8  d   QhRRRR/# r   r:   )r;   s   "r<   r=   r>   X  s      !3  r?   c                	    R # rs   r:   r   s   &&r<   notify_closingAsyncBackend.notify_closingV  r}   r?   c                    V ^8  d   QhRRRR/# r   r:   )r;   s   "r<   r=   r>   ]  s      f  r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_listener_socket!AsyncBackend.wrap_listener_socket[  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r$   r:   )r;   s   "r<   r=   r>   b  s      F | r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_stream_socketAsyncBackend.wrap_stream_socket`  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r'   r:   )r;   s   "r<   r=   r>   g  s       <L r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_unix_stream_socket$AsyncBackend.wrap_unix_stream_sockete  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r%   r:   )r;   s   "r<   r=   r>   l  s       I r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_udp_socketAsyncBackend.wrap_udp_socketj  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r    r:   )r;   s   "r<   r=   r>   q        6 >P r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_connected_udp_socket&AsyncBackend.wrap_connected_udp_socketo  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r&   r:   )r;   s   "r<   r=   r>   v  r  r?   c                	   "   R # 5irs   r:   r   s   &&r<   wrap_unix_datagram_socket&AsyncBackend.wrap_unix_datagram_sockett  r   r\   c                    V ^8  d   QhRRRR/# )r1   r   r   r9   r!   r:   )r;   s   "r<   r=   r>   {  s      	$r?   c                	   "   R # 5irs   r:   r   s   &&r<   #wrap_connected_unix_datagram_socket0AsyncBackend.wrap_connected_unix_datagram_sockety  r   r\   c                   V ^8  d   QhRR/# )r1   r9   r   r:   )r;   s   "r<   r=   r>     s       r?   c                	    R # rs   r:   rH   s   &r<   current_default_thread_limiter+AsyncBackend.current_default_thread_limiter  r}   r?   c                    V ^8  d   QhRRRR/# )r1   signalsr   r9   z.AbstractContextManager[AsyncIterator[Signals]]r:   )r;   s   "r<   r=   r>     s      	7r?   c                	    R # rs   r:   )rA   r#  s   &*r<   open_signal_receiver!AsyncBackend.open_signal_receiver  ru   r?   c                   V ^8  d   QhRR/# )r1   r9   r   r:   )r;   s   "r<   r=   r>     s       r?   c                	    R # rs   r:   rH   s   &r<   get_current_taskAsyncBackend.get_current_task  r}   r?   c                   V ^8  d   QhRR/# )r1   r9   zSequence[TaskInfo]r:   )r;   s   "r<   r=   r>     s      "4 r?   c                	    R # rs   r:   rH   s   &r<   get_running_tasksAsyncBackend.get_running_tasks  r}   r?   c                   V ^8  d   QhRR/# rV   r:   )r;   s   "r<   r=   r>     s      T r?   c                	   "   R # 5irs   r:   rH   s   &r<   wait_all_tasks_blocked#AsyncBackend.wait_all_tasks_blocked  r   r\   c                    V ^8  d   QhRRRR/# )r1   r8   r7   r9   r*   r:   )r;   s   "r<   r=   r>     s       J r?   c                	    R # rs   r:   )rA   r8   s   &&r<   create_test_runnerAsyncBackend.create_test_runner  r}   r?   r:   )FNrs   )r   )7__name__
__module____qualname____firstlineno__classmethodr   rB   rI   rO   rS   rY   rb   ri   rh   r`   ra   rg   r_   r{   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r  r  r  r   r%  r)  r-  r1  r5  __static_attributes__r:   r?   r<   r/   r/   7   sf     (       U  U    	# 	# 	 	    "&((;@  
 
  
           !%	
 #                  	  	      
             !  ! *  *   
 
 '( "#    (   
                              
      
            r?   r/   )	metaclass)      )r>  
   )C__conditional_annotations__
__future__r   r`   sysabcr   r   collections.abcr   r   r   r	   
contextlibr
   osr   signalr   r   r   r   typingr   r   r   r   r   r   version_infor   r   typing_extensionsr   	_typeshedr   _core._synchronizationr   r   r   r   _core._tasksr   _core._testingr   _socketsr    r!   r"   r#   r$   r%   r&   r'   _subprocessesr(   _tasksr)   _testingr*   r+   r,   r   bytesr-   __annotations__r/   )rA  s   @r<   <module>rV     s    " "  
 ' H H -   4 4  w++6w +,PP*)	 	 	 '!$:
#!#uo?P"PQ	 QgW gr?   