+
    P\i)  c                  s  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            
      s.   ] 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          
     s,    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)    Zformat   "9/usr/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
Nr6   )clsr.   r0   r2   r4      &&&&&r9   runZAsyncBackend.run8       r<   c                   V ^8  d   QhRR/# )r-   r5   objectr6   r7   r8   r9   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
Nr6   r>      &r9   current_tokenZAsyncBackend.current_tokenN   rA   r<   c               rB   r-   r5   floatr6   r7   r8   r9   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)
Nr6   rD   rE   r9   current_timeZAsyncBackend.current_timeX   rA   r<   c               rB   )r-   r5   ztype[BaseException]r6   r7   r8   r9   r:   r;   c   s     U U*= Ur<   c                r=   )zFReturn the exception class that is raised in a task if it's cancelled.Nr6   rD   rE   r9   cancelled_exception_classZ&AsyncBackend.cancelled_exception_classa   rA   r<   c               rB   r-   r5   Noner6   r7   r8   r9   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`.
Nr6   rD   rE   r9   
checkpointZAsyncBackend.checkpointf           c               rB   rK   r6   r7   r8   r9   r:   r;   q   s     	# 	#d 	#r<   c                s   "   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infrN   rD   rE   r9   checkpoint_if_cancelledZ$AsyncBackend.checkpoint_if_cancelledp   s6      ))+y8..""" 9"s   8AA	Ac               rB   rK   r6   r7   r8   r9   r:   r;   }   s     	 	 	r<   c                s   "   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sleeprD   rE   r9   cancel_shielded_checkpointZ'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/# )r-   delayrH   r5   rL   r6   r7   r8   r9   r:   r;      s       $ r<   c                rM   )z\
Pause the current task for the specified duration.

:param delay: the duration, in seconds
Nr6   )r>   rZ      &&r9   rW   ZAsyncBackend.sleep   rO   rP   deadlinerU   Fc               $    V ^8  d   QhRRRRRR/# )r-   r\   rH   rU   boolr5   r   r6   r7   r8   r9   r:   r;      s$      48	r<   c               	    R # Nr6   )r>   r\   rU   s   &$$r9   rV   Z AsyncBackend.create_cancel_scope       
 	r<   c               rB   rG   r6   r7   r8   r9   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
Nr6   rD   rE   r9   rQ   Z'AsyncBackend.current_effective_deadline   rA   r<   c               rB   )r-   r5   r'   r6   r7   r8   r9   r:   r;      s      ) r<   c                	r_   r`   r6   rD   rE   r9   create_task_groupZAsyncBackend.create_task_group        	r<   c               rB   )r-   r5   r   r6   r7   r8   r9   r:   r;      s      U r<   c                	r_   r`   r6   rD   rE   r9   create_eventZAsyncBackend.create_event   rc   r<   c               rY   )r-   fast_acquirer^   r5   r   r6   r7   r8   r9   r:   r;      s      $ 4 r<   c               	r_   r`   r6   )r>   re   s   &$r9   create_lockZAsyncBackend.create_lock   rc   r<   	max_valueNre   c               (    V ^8  d   QhRRRRRRRR/# )	r-   initial_valueintrg   z
int | Nonere   r^   r5   r   r6   r7   r8   r9   r:   r;      s2       	
  
r<   c               	r_   r`   r6   )r>   ri   rg   re   s   &&$$r9   create_semaphoreZAsyncBackend.create_semaphore   s     	r<   c               rY   )r-   total_tokensrH   r5   r   r6   r7   r8   r9   r:   r;      s      5 _ r<   c                	r_   r`   r6   )r>   rl   r[   r9   create_capacity_limiterZ$AsyncBackend.create_capacity_limiter   rc   r<   c          
     s,    V ^8  d   QhRRRRRRRRR	R
/# )r-   r.   &Callable[[Unpack[PosArgsT]], T_Retval]r0   r1   abandon_on_cancelr^   limiterzCapacityLimiter | Noner5   r)   r6   r7   r8   r9   r:   r;      s<      4 &  	
 ( 
r<   c                	   "   R # 5ir`   r6   )r>   r.   r0   ro   rp   r?   r9   run_sync_in_worker_threadZ&AsyncBackend.run_sync_in_worker_thread   
      	rP   c               rB   rK   r6   r7   r8   r9   r:   r;      s       r<   c                	r_   r`   r6   rD   rE   r9   check_cancelledZAsyncBackend.check_cancelled   rc   r<   c               rh   )	r-   r.   r/   r0   r1   tokenrC   r5   r)   r6   r7   r8   r9   r:   r;      s2      ? & 	
 
r<   c                	r_   r`   r6   r>   r.   r0   ru      &&&&r9   run_async_from_threadZ"AsyncBackend.run_async_from_thread        	r<   c               rh   )	r-   r.   rn   r0   r1   ru   rC   r5   r)   r6   r7   r8   r9   r:   r;      s2      4 & 	
 
r<   c                	r_   r`   r6   rv   rw   r9   run_sync_from_threadZ!AsyncBackend.run_sync_from_thread   ry   r<   c               s0    V ^8  d   QhRRRRRRRRRRR	R
/# )r-   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]stdinzint | IO[Any] | Nonestdoutstderrr2   r   r5   r&   r6   r7   r8   r9   r:   r;      sF     	 	:	 $		
 %	 %	 	 
	r<   c               	rq   r`   r6   )r>   r{   r|   r}   r~   r2   s   &&$$$,r9   open_processZAsyncBackend.open_process   s
      	rP   c               rY   )r-   workerszset[Process]r5   rL   r6   r7   r8   r9   r:   r;      s      , 4 r<   c                	r_   r`   r6   )r>   r   r[   r9   #setup_process_pool_exit_at_shutdownZ0AsyncBackend.setup_process_pool_exit_at_shutdown   rc   r<   c               rh   )	r-   hoststrportrj   local_addressIPSockAddrType | Noner5   r"   r6   r7   r8   r9   r:   r;      s,      !2G	r<   c                	rq   r`   r6   )r>   r   r   r   rw   r9   connect_tcpZAsyncBackend.connect_tcp   
     
 	rP   c               rY   )r-   pathstr | bytesr5   r%   r6   r7   r8   r9   r:   r;     s      k 6F r<   c                	rq   r`   r6   )r>   r   r[   r9   connect_unixZAsyncBackend.connect_unix  
      	rP   c               rY   r-   sockr   r5   r!   r6   r7   r8   r9   r:   r;   	  s      v . r<   c                	r_   r`   r6   r>   r   r[   r9   create_tcp_listenerZ AsyncBackend.create_tcp_listener  rc   r<   c               rY   r   r6   r7   r8   r9   r:   r;     s       > r<   c                	r_   r`   r6   r   r[   r9   create_unix_listenerZ!AsyncBackend.create_unix_listener  rc   r<   c          
     s,    V ^8  d   QhRRRRRRRRRR	/# )
r-   familyr   r   r   remote_address
reuse_portr^   r5   zUDPSocket | ConnectedUDPSocketr6   r7   r8   r9   r:   r;     s<       - .	
  
(r<   c                	rq   r`   r6   )r>   r   r   r   r   r?   r9   create_udp_socketZAsyncBackend.create_udp_socket  rs   rP   c               r]   )r-   
raw_socketr   remote_pathrL   r5   r$   r6   r7   r8   r9   r:   r;     s$     ! !!.2!	!r<   c                	rq   r`   r6   r>   r   r      &&&r9   create_unix_datagram_socket(AsyncBackend.create_unix_datagram_socket  s
      !rP   c               r]   )r-   r   r   r   r   r5   r   r6   r7   r8   r9   r:   r;   $  s$     * **.9*	$*r<   c                	rq   r`   r6   r   r   r9   r   r   "  s
      '*rP   c               r]   )r-   r   r   r   zstr | bytes | Noner5   z0UNIXDatagramSocket | ConnectedUNIXDatagramSocketr6   r7   r8   r9   r:   r;   *  s$      .@	9r<   c                	rq   r`   r6   r   r   r9   r   r   (  r   rP   r   typeprotoflagsc               s4    V ^8  d   QhRRRRRRRRR	R
RR
RR/# )r-   r   zbytes | str | Noner   zstr | int | Noner   zint | AddressFamilyr   zint | SocketKindr   rj   r   r5   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]r6   r7   r8   r9   r:   r;   1  sP        
 $   
r<   c               	rq   r`   r6   )r>   r   r   r   r   r   r   s   &&&$$$$r9   getaddrinfoZAsyncBackend.getaddrinfo/  s
     ( 	rP   c               r]   )r-   sockaddrr    r   rj   r5   ztuple[str, str]r6   r7   r8   r9   r:   r;   G  s$      %.1	r<   c                	rq   r`   r6   )r>   r   r   r   r9   getnameinfoZAsyncBackend.getnameinfoE  r   rP   c               rY   r-   objr   r5   rL   r6   r7   r8   r9   r:   r;   N        &8 T r<   c                	rq   r`   r6   r>   r   r[   r9   wait_readableZAsyncBackend.wait_readableL  r   rP   c               rY   r   r6   r7   r8   r9   r:   r;   S  r   r<   c                	rq   r`   r6   r   r[   r9   wait_writableZAsyncBackend.wait_writableQ  r   rP   c               rY   r   r6   r7   r8   r9   r:   r;   X  s      !3  r<   c                	r_   r`   r6   r   r[   r9   notify_closingZAsyncBackend.notify_closingV  rc   r<   c               rY   r   r6   r7   r8   r9   r:   r;   ]  s      f  r<   c                	rq   r`   r6   r   r[   r9   wrap_listener_socketZ!AsyncBackend.wrap_listener_socket[  r   rP   c               rY   )r-   r   r   r5   r"   r6   r7   r8   r9   r:   r;   b  s      F | r<   c                	rq   r`   r6   r   r[   r9   wrap_stream_socketZAsyncBackend.wrap_stream_socket`  r   rP   c               rY   )r-   r   r   r5   r%   r6   r7   r8   r9   r:   r;   g  s       <L r<   c                	rq   r`   r6   r   r[   r9   wrap_unix_stream_socketZ$AsyncBackend.wrap_unix_stream_sockete  r   rP   c               rY   )r-   r   r   r5   r#   r6   r7   r8   r9   r:   r;   l  s       I r<   c                	rq   r`   r6   r   r[   r9   wrap_udp_socketZAsyncBackend.wrap_udp_socketj  r   rP   c               rY   )r-   r   r   r5   r   r6   r7   r8   r9   r:   r;   q        6 >P r<   c                	rq   r`   r6   r   r[   r9   wrap_connected_udp_socketZ&AsyncBackend.wrap_connected_udp_socketo  r   rP   c               rY   )r-   r   r   r5   r$   r6   r7   r8   r9   r:   r;   v  r   r<   c                	rq   r`   r6   r   r[   r9   wrap_unix_datagram_socketZ&AsyncBackend.wrap_unix_datagram_sockett  r   rP   c               rY   )r-   r   r   r5   r   r6   r7   r8   r9   r:   r;   {  s      	$r<   c                	rq   r`   r6   r   r[   r9   #wrap_connected_unix_datagram_socketZ0AsyncBackend.wrap_connected_unix_datagram_sockety  r   rP   c               rB   )r-   r5   r   r6   r7   r8   r9   r:   r;     s       r<   c                	r_   r`   r6   rD   rE   r9   current_default_thread_limiterZ+AsyncBackend.current_default_thread_limiter  rc   r<   c               rY   )r-   signalsr
   r5   z.AbstractContextManager[AsyncIterator[Signals]]r6   r7   r8   r9   r:   r;     s      	7r<   c                	r_   r`   r6   )r>   r   s   &*r9   open_signal_receiverZ!AsyncBackend.open_signal_receiver  ra   r<   c               rB   )r-   r5   r   r6   r7   r8   r9   r:   r;     s       r<   c                	r_   r`   r6   rD   rE   r9   get_current_taskZAsyncBackend.get_current_task  rc   r<   c               rB   )r-   r5   zSequence[TaskInfo]r6   r7   r8   r9   r:   r;     s      "4 r<   c                	r_   r`   r6   rD   rE   r9   get_running_tasksZAsyncBackend.get_running_tasks  rc   r<   c               rB   rK   r6   r7   r8   r9   r:   r;     s      T r<   c                	rq   r`   r6   rD   rE   r9   wait_all_tasks_blockedZ#AsyncBackend.wait_all_tasks_blocked  r   rP   c               rY   )r-   r4   r3   r5   r(   r6   r7   r8   r9   r:   r;     s       J r<   c                	r_   r`   r6   )r>   r4   r[   r9   create_test_runnerZAsyncBackend.create_test_runner  rc   r<   r6   )FNr`   )r    )7Z__name__Z
__module__Z__qualname__Z__firstlineno__Zclassmethodr   r@   rF   rI   rJ   rN   rT   rX   rW   rR   rS   rV   rQ   rb   rd   rf   rk   rm   rr   rt   rx   rz   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   Z__static_attributes__r6   r<   r9   r,   r,   7   sf     (       U  U    	# 	# 	 	    "&((;@  
 
  
           !%	
 #                  	  	      
             !  ! *  *   
 
 '( "#    (   
                              
      
            r<   r,   )Z	metaclass)   i   )r   i
   )C__conditional_annotations__Z
__future__r   rR   ZsysZabcr   r   Zcollections.abcr   r   r   r   Z
contextlibr   Zosr	   Zsignalr
   r   r   r   Ztypingr   r   r   r   r   r   Zversion_infor   r   Ztyping_extensionsr   Z	_typeshedr   Z_core._synchronizationr   r   r   r   Z_core._tasksr   Z_core._testingr   Z_socketsr   r   r    r!   r"   r#   r$   r%   Z_subprocessesr&   Z_tasksr'   Z_testingr(   r)   r*   r   Zbytesr+   Z__annotations__r,   )r   s   @r9   <module>r      s    " "  
 ' H H -   4 4  w++6w +,PP*)	 	 	 '!$:
#!#uo?P"PQ	 QgW gr<   