+
    Xj)                    *  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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  ]'       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RR7      t=]! R4      t>]?]@,          ]]?,          ,          ]]@,          ,          tAR]BR&    ! R R]R7      tCR# )    )annotationsN)ABCMetaabstractmethod)AsyncIterator	AwaitableCallable	CoroutineSequence)AbstractContextManager)PathLike)Signals)AddressFamily
SocketKindsocket)IOTYPE_CHECKINGAny	TypeAliasTypeVaroverload)TypeVarTupleUnpack)FileDescriptorLike)CapacityLimiterEventLock	Semaphore)CancelScope)TaskInfo)ConnectedUDPSocketConnectedUNIXDatagramSocketIPSockAddrTypeSocketListenerSocketStream	UDPSocketUNIXDatagramSocketUNIXSocketStream)Process)	TaskGroup)
TestRunnerT_RetvalT_coT)	covariantPosArgsTr   StrOrBytesPathc            
      .   ] tR t^3t]]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	/# )
   funcz1Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]]argstuple[Unpack[PosArgsT]]kwargsdict[str, Any]optionsreturnr+    )formats   "p   /Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/abc/_eventloop.py__annotate__AsyncBackend.__annotate__6   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;   )clsr4   r5   r7   r9   s   &&&&&r=   runAsyncBackend.run4       r@   c                   V ^8  d   QhRR/# )r3   r:   objectr;   )r<   s   "r=   r>   r?   L   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;   rB   s   &r=   current_tokenAsyncBackend.current_tokenJ   rE   r@   c                   V ^8  d   QhRR/# r3   r:   floatr;   )r<   s   "r=   r>   r?   V   s      U r@   c                    R# )zb
Return the current value of the event loop's internal clock.

:return: the clock value (seconds)
Nr;   rI   s   &r=   current_timeAsyncBackend.current_timeT   rE   r@   c                   V ^8  d   QhRR/# )r3   r:   ztype[BaseException]r;   )r<   s   "r=   r>   r?   _   s     U U*= Ur@   c                    R# )zFReturn the exception class that is raised in a task if it's cancelled.Nr;   rI   s   &r=   cancelled_exception_class&AsyncBackend.cancelled_exception_class]   rE   r@   c                   V ^8  d   QhRR/# r3   r:   Noner;   )r<   s   "r=   r>   r?   d   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;   rI   s   &r=   
checkpointAsyncBackend.checkpointb           c                   V ^8  d   QhRR/# rW   r;   )r<   s   "r=   r>   r?   m   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infrZ   rI   s   &r=   checkpoint_if_cancelled$AsyncBackend.checkpoint_if_cancelledl   s6      ))+y8..""" 9"s   8AA	Ac                   V ^8  d   QhRR/# rW   r;   )r<   s   "r=   r>   r?   y   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sleeprI   s   &r=   cancel_shielded_checkpoint'AsyncBackend.cancel_shielded_checkpointx   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/# )r3   delayrN   r:   rX   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;   )rB   rm   s   &&r=   ri   AsyncBackend.sleep   r\   r]   deadlinerg   Fc               $    V ^8  d   QhRRRRRR/# )r3   rp   rN   rg   boolr:   r   r;   )r<   s   "r=   r>   r?      s$      48	r@   c               	    R # Nr;   )rB   rp   rg   s   &$$r=   rh    AsyncBackend.create_cancel_scope       
 	r@   c                   V ^8  d   QhRR/# rM   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;   rI   s   &r=   r`   'AsyncBackend.current_effective_deadline   rE   r@   c                   V ^8  d   QhRR/# )r3   r:   r)   r;   )r<   s   "r=   r>   r?      s      ) r@   c                	    R # rt   r;   rI   s   &r=   create_task_groupAsyncBackend.create_task_group        	r@   c                   V ^8  d   QhRR/# )r3   r:   r   r;   )r<   s   "r=   r>   r?      s      U r@   c                	    R # rt   r;   rI   s   &r=   create_eventAsyncBackend.create_event   r~   r@   c                    V ^8  d   QhRRRR/# )r3   fast_acquirerr   r:   r   r;   )r<   s   "r=   r>   r?      s      $ 4 r@   c               	    R # rt   r;   )rB   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/# )	r3   initial_valueintr   z
int | Noner   rr   r:   r   r;   )r<   s   "r=   r>   r?      s2       	
  
r@   c               	    R # rt   r;   )rB   r   r   r   s   &&$$r=   create_semaphoreAsyncBackend.create_semaphore   s     	r@   c                    V ^8  d   QhRRRR/# )r3   total_tokensrN   r:   r   r;   )r<   s   "r=   r>   r?      s      5 _ r@   c                	    R # rt   r;   )rB   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
/# )r3   r4   &Callable[[Unpack[PosArgsT]], T_Retval]r5   r6   abandon_on_cancelrr   limiterzCapacityLimiter | Noner:   r+   r;   )r<   s   "r=   r>   r?      s<      4 &  	
 ( 
r@   c                	   "   R # 5irt   r;   )rB   r4   r5   r   r   s   &&&&&r=   run_sync_in_worker_thread&AsyncBackend.run_sync_in_worker_thread   
      	r]   c                   V ^8  d   QhRR/# rW   r;   )r<   s   "r=   r>   r?      s       r@   c                	    R # rt   r;   rI   s   &r=   check_cancelledAsyncBackend.check_cancelled   r~   r@   c               (    V ^8  d   QhRRRRRRRR/# )	r3   r4   z7Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]]r5   r6   tokenrG   r:   r,   r;   )r<   s   "r=   r>   r?      s2      E & 	
 
r@   c                	    R # rt   r;   rB   r4   r5   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/# )	r3   r4   r   r5   r6   r   rG   r:   r+   r;   )r<   s   "r=   r>   r?      s2      4 & 	
 
r@   c                	    R # rt   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
/# )r3   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]stdinzint | IO[Any] | Nonestdoutstderrr7   r   r:   r(   r;   )r<   s   "r=   r>   r?      sF     	 	:	 $		
 %	 %	 	 
	r@   c               	   "   R # 5irt   r;   )rB   r   r   r   r   r7   s   &&$$$,r=   open_processAsyncBackend.open_process   s
      	r]   c                    V ^8  d   QhRRRR/# )r3   workerszset[Process]r:   rX   r;   )r<   s   "r=   r>   r?      s      , 4 r@   c                	    R # rt   r;   )rB   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/# )	r3   hoststrportr   local_addressIPSockAddrType | Noner:   r$   r;   )r<   s   "r=   r>   r?      s,      !2G	r@   c                	   "   R # 5irt   r;   )rB   r   r   r   s   &&&&r=   connect_tcpAsyncBackend.connect_tcp   
     
 	r]   c                    V ^8  d   QhRRRR/# )r3   pathstr | bytesr:   r'   r;   )r<   s   "r=   r>   r?      s      k 6F r@   c                	   "   R # 5irt   r;   )rB   r   s   &&r=   connect_unixAsyncBackend.connect_unix   
      	r]   c                    V ^8  d   QhRRRR/# r3   sockr   r:   r#   r;   )r<   s   "r=   r>   r?     s      v . r@   c                	    R # rt   r;   rB   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 # rt   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	/# )
r3   familyr   r   r   remote_address
reuse_portrr   r:   zUDPSocket | ConnectedUDPSocketr;   )r<   s   "r=   r>   r?     s<       - .	
  
(r@   c                	   "   R # 5irt   r;   )rB   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/# )r3   
raw_socketr   remote_pathrX   r:   r&   r;   )r<   s   "r=   r>   r?     s$     ! !!.2!	!r@   c                	   "   R # 5irt   r;   rB   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/# )r3   r   r   r   r   r:   r!   r;   )r<   s   "r=   r>   r?      s$     * **.9*	$*r@   c                	   "   R # 5irt   r;   r   s   &&&r=   r   r     s
      '*r]   c               $    V ^8  d   QhRRRRRR/# )r3   r   r   r   zstr | bytes | Noner:   z0UNIXDatagramSocket | ConnectedUNIXDatagramSocketr;   )r<   s   "r=   r>   r?   &  s$      .@	9r@   c                	   "   R # 5irt   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/# )r3   r   zbytes | str | Noner   zstr | int | Noner   zint | AddressFamilyr   zint | SocketKindr   r   r   r:   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]r;   )r<   s   "r=   r>   r?   -  sP        
 $   
r@   c               	   "   R # 5irt   r;   )rB   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/# )r3   sockaddrr"   r   r   r:   ztuple[str, str]r;   )r<   s   "r=   r>   r?   C  s$      %.1	r@   c                	   "   R # 5irt   r;   )rB   r   r   s   &&&r=   getnameinfoAsyncBackend.getnameinfoA  r   r]   c                    V ^8  d   QhRRRR/# r3   objr   r:   rX   r;   )r<   s   "r=   r>   r?   J        &8 T r@   c                	   "   R # 5irt   r;   rB   r   s   &&r=   wait_readableAsyncBackend.wait_readableH  r   r]   c                    V ^8  d   QhRRRR/# r   r;   )r<   s   "r=   r>   r?   O  r   r@   c                	   "   R # 5irt   r;   r   s   &&r=   wait_writableAsyncBackend.wait_writableM  r   r]   c                    V ^8  d   QhRRRR/# r   r;   )r<   s   "r=   r>   r?   T  s      !3  r@   c                	    R # rt   r;   r   s   &&r=   notify_closingAsyncBackend.notify_closingR  r~   r@   c                    V ^8  d   QhRRRR/# r   r;   )r<   s   "r=   r>   r?   Y  s      f  r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_listener_socket!AsyncBackend.wrap_listener_socketW  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r$   r;   )r<   s   "r=   r>   r?   ^  s      F | r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_stream_socketAsyncBackend.wrap_stream_socket\  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r'   r;   )r<   s   "r=   r>   r?   c  s       <L r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_unix_stream_socket$AsyncBackend.wrap_unix_stream_socketa  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r%   r;   )r<   s   "r=   r>   r?   h  s       I r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_udp_socketAsyncBackend.wrap_udp_socketf  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r    r;   )r<   s   "r=   r>   r?   m        6 >P r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_connected_udp_socket&AsyncBackend.wrap_connected_udp_socketk  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r&   r;   )r<   s   "r=   r>   r?   r  r  r@   c                	   "   R # 5irt   r;   r   s   &&r=   wrap_unix_datagram_socket&AsyncBackend.wrap_unix_datagram_socketp  r   r]   c                    V ^8  d   QhRRRR/# )r3   r   r   r:   r!   r;   )r<   s   "r=   r>   r?   w  s      	$r@   c                	   "   R # 5irt   r;   r   s   &&r=   #wrap_connected_unix_datagram_socket0AsyncBackend.wrap_connected_unix_datagram_socketu  r   r]   c                   V ^8  d   QhRR/# )r3   r:   r   r;   )r<   s   "r=   r>   r?   ~  s       r@   c                	    R # rt   r;   rI   s   &r=   current_default_thread_limiter+AsyncBackend.current_default_thread_limiter|  r~   r@   c                    V ^8  d   QhRRRR/# )r3   signalsr   r:   z.AbstractContextManager[AsyncIterator[Signals]]r;   )r<   s   "r=   r>   r?     s      	7r@   c                	    R # rt   r;   )rB   r$  s   &*r=   open_signal_receiver!AsyncBackend.open_signal_receiver  rv   r@   c                   V ^8  d   QhRR/# )r3   r:   r   r;   )r<   s   "r=   r>   r?     s       r@   c                	    R # rt   r;   rI   s   &r=   get_current_taskAsyncBackend.get_current_task  r~   r@   c                   V ^8  d   QhRR/# )r3   r:   zSequence[TaskInfo]r;   )r<   s   "r=   r>   r?     s      "4 r@   c                	    R # rt   r;   rI   s   &r=   get_running_tasksAsyncBackend.get_running_tasks  r~   r@   c                   V ^8  d   QhRR/# rW   r;   )r<   s   "r=   r>   r?     s      T r@   c                	   "   R # 5irt   r;   rI   s   &r=   wait_all_tasks_blocked#AsyncBackend.wait_all_tasks_blocked  r   r]   c                    V ^8  d   QhRRRR/# )r3   r9   r8   r:   r*   r;   )r<   s   "r=   r>   r?     s       J r@   c                	    R # rt   r;   )rB   r9   s   &&r=   create_test_runnerAsyncBackend.create_test_runner  r~   r@   r;   )FNrt   )r   )7__name__
__module____qualname____firstlineno__classmethodr   rC   rJ   rP   rT   rZ   rc   rj   ri   ra   rb   rh   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.  r2  r6  __static_attributes__r;   r@   r=   r1   r1   3   sf     (       U  U    	# 	# 	 	    "&((;@  
 
  
           !%	
 #                  	  	      
             !  ! *  *   
 
 '( "#    (   
                              
      
            r@   r1   )	metaclass)      )D__conditional_annotations__
__future__r   ra   sysabcr   r   collections.abcr   r   r   r	   r
   
contextlibr   osr   signalr   r   r   r   typingr   r   r   r   r   r   version_infor   r   typing_extensions	_typeshedr   _core._synchronizationr   r   r   r   _core._tasksr   _core._testingr   _socketsr    r!   r"   r#   r$   r%   r&   r'   _subprocessesr(   _tasksr)   _testingr*   r+   r,   r.   r   bytesr/   __annotations__r1   )rA  s   @r=   <module>rV     s    " "  
 ' S S -   4 4  w++6,PP*)	 	 	 '!$:v&
#%K(3-7(5/I	 IgW gr@   