+
    @i)                      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 ]'       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.H/t/H0t0H1t1H2t2H3t3H4t4 ^RI5H6t6 ^RI7H8t8 ^RI9H:t: ]! R4      t;]! R4      t<]=]>,          ]]=,          ,          ]]>,          ,          t?R]@R&    ! R R]R7      tAR# )    )annotationsN)ABCMetaabstractmethod)AsyncIterator	AwaitableCallable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PosArgsTr   StrOrBytesPathc            
      .   ] tR t^2t]]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/var/www/html/photoedit/myenv/lib/python3.14/site-packages/anyio/abc/_eventloop.py__annotate__AsyncBackend.__annotate__5   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
Nr9   )clsr1   r3   r5   r7   s   &&&&&r;   runAsyncBackend.run3       r>   c                   V ^8  d   QhRR/# )r0   r8   objectr9   )r:   s   "r;   r<   r=   K   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
Nr9   r@   s   &r;   current_tokenAsyncBackend.current_tokenI   rC   r>   c                   V ^8  d   QhRR/# r0   r8   floatr9   )r:   s   "r;   r<   r=   U   s      U r>   c                    R# )zb
Return the current value of the event loop's internal clock.

:return: the clock value (seconds)
Nr9   rG   s   &r;   current_timeAsyncBackend.current_timeS   rC   r>   c                   V ^8  d   QhRR/# )r0   r8   ztype[BaseException]r9   )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.Nr9   rG   s   &r;   cancelled_exception_class&AsyncBackend.cancelled_exception_class\   rC   r>   c                   V ^8  d   QhRR/# r0   r8   Noner9   )r:   s   "r;   r<   r=   c   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`.
Nr9   rG   s   &r;   
checkpointAsyncBackend.checkpointa           c                   V ^8  d   QhRR/# rU   r9   )r:   s   "r;   r<   r=   l   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infrX   rG   s   &r;   checkpoint_if_cancelled$AsyncBackend.checkpoint_if_cancelledk   s6      ))+y8..""" 9"s   8AA	Ac                   V ^8  d   QhRR/# rU   r9   )r:   s   "r;   r<   r=   x   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sleeprG   s   &r;   cancel_shielded_checkpoint'AsyncBackend.cancel_shielded_checkpointw   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/# )r0   delayrL   r8   rV   r9   )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
Nr9   )r@   rk   s   &&r;   rg   AsyncBackend.sleep   rZ   r[   deadlinere   Fc               $    V ^8  d   QhRRRRRR/# )r0   rn   rL   re   boolr8   r   r9   )r:   s   "r;   r<   r=      s$      48	r>   c               	    R # Nr9   )r@   rn   re   s   &$$r;   rf    AsyncBackend.create_cancel_scope       
 	r>   c                   V ^8  d   QhRR/# rK   r9   )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
Nr9   rG   s   &r;   r^   'AsyncBackend.current_effective_deadline   rC   r>   c                   V ^8  d   QhRR/# )r0   r8   r(   r9   )r:   s   "r;   r<   r=      s      ) r>   c                	    R # rr   r9   rG   s   &r;   create_task_groupAsyncBackend.create_task_group        	r>   c                   V ^8  d   QhRR/# )r0   r8   r   r9   )r:   s   "r;   r<   r=      s      U r>   c                	    R # rr   r9   rG   s   &r;   create_eventAsyncBackend.create_event   r|   r>   c                    V ^8  d   QhRRRR/# )r0   fast_acquirerp   r8   r   r9   )r:   s   "r;   r<   r=      s      $ 4 r>   c               	    R # rr   r9   )r@   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/# )	r0   initial_valueintr   z
int | Noner   rp   r8   r   r9   )r:   s   "r;   r<   r=      s2       	
  
r>   c               	    R # rr   r9   )r@   r   r   r   s   &&$$r;   create_semaphoreAsyncBackend.create_semaphore   s     	r>   c                    V ^8  d   QhRRRR/# )r0   total_tokensrL   r8   r   r9   )r:   s   "r;   r<   r=      s      5 _ r>   c                	    R # rr   r9   )r@   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
/# )r0   r1   &Callable[[Unpack[PosArgsT]], T_Retval]r3   r4   abandon_on_cancelrp   limiterzCapacityLimiter | Noner8   r*   r9   )r:   s   "r;   r<   r=      s<      4 &  	
 ( 
r>   c                	   "   R # 5irr   r9   )r@   r1   r3   r   r   s   &&&&&r;   run_sync_in_worker_thread&AsyncBackend.run_sync_in_worker_thread   
      	r[   c                   V ^8  d   QhRR/# rU   r9   )r:   s   "r;   r<   r=      s       r>   c                	    R # rr   r9   rG   s   &r;   check_cancelledAsyncBackend.check_cancelled   r|   r>   c               (    V ^8  d   QhRRRRRRRR/# )	r0   r1   r2   r3   r4   tokenrE   r8   r*   r9   )r:   s   "r;   r<   r=      s2      ? & 	
 
r>   c                	    R # rr   r9   r@   r1   r3   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/# )	r0   r1   r   r3   r4   r   rE   r8   r*   r9   )r:   s   "r;   r<   r=      s2      4 & 	
 
r>   c                	    R # rr   r9   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
/# )r0   commandz)StrOrBytesPath | Sequence[StrOrBytesPath]stdinzint | IO[Any] | Nonestdoutstderrr5   r   r8   r'   r9   )r:   s   "r;   r<   r=      sF     	 	:	 $		
 %	 %	 	 
	r>   c               	   "   R # 5irr   r9   )r@   r   r   r   r   r5   s   &&$$$,r;   open_processAsyncBackend.open_process   s
      	r[   c                    V ^8  d   QhRRRR/# )r0   workerszset[Process]r8   rV   r9   )r:   s   "r;   r<   r=      s      , 4 r>   c                	    R # rr   r9   )r@   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/# )	r0   hoststrportr   local_addressIPSockAddrType | Noner8   r#   r9   )r:   s   "r;   r<   r=      s,      !2G	r>   c                	   "   R # 5irr   r9   )r@   r   r   r   s   &&&&r;   connect_tcpAsyncBackend.connect_tcp   
     
 	r[   c                    V ^8  d   QhRRRR/# )r0   pathstr | bytesr8   r&   r9   )r:   s   "r;   r<   r=      s      k 6F r>   c                	   "   R # 5irr   r9   )r@   r   s   &&r;   connect_unixAsyncBackend.connect_unix   
      	r[   c                    V ^8  d   QhRRRR/# r0   sockr   r8   r"   r9   )r:   s   "r;   r<   r=     s      v . r>   c                	    R # rr   r9   r@   r   s   &&r;   create_tcp_listener AsyncBackend.create_tcp_listener  r|   r>   c                    V ^8  d   QhRRRR/# r   r9   )r:   s   "r;   r<   r=   	  s       > r>   c                	    R # rr   r9   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	/# )
r0   familyr   r   r   remote_address
reuse_portrp   r8   zUDPSocket | ConnectedUDPSocketr9   )r:   s   "r;   r<   r=     s<       - .	
  
(r>   c                	   "   R # 5irr   r9   )r@   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/# )r0   
raw_socketr   remote_pathrV   r8   r%   r9   )r:   s   "r;   r<   r=     s$     ! !!.2!	!r>   c                	   "   R # 5irr   r9   r@   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/# )r0   r   r   r   r   r8   r    r9   )r:   s   "r;   r<   r=     s$     * **.9*	$*r>   c                	   "   R # 5irr   r9   r   s   &&&r;   r   r     s
      '*r[   c               $    V ^8  d   QhRRRRRR/# )r0   r   r   r   zstr | bytes | Noner8   z0UNIXDatagramSocket | ConnectedUNIXDatagramSocketr9   )r:   s   "r;   r<   r=   %  s$      .@	9r>   c                	   "   R # 5irr   r9   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/# )r0   r   zbytes | str | Noner   zstr | int | Noner   zint | AddressFamilyr   zint | SocketKindr   r   r   r8   zuSequence[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]r9   )r:   s   "r;   r<   r=   ,  sP        
 $   
r>   c               	   "   R # 5irr   r9   )r@   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/# )r0   sockaddrr!   r   r   r8   ztuple[str, str]r9   )r:   s   "r;   r<   r=   B  s$      %.1	r>   c                	   "   R # 5irr   r9   )r@   r   r   s   &&&r;   getnameinfoAsyncBackend.getnameinfo@  r   r[   c                    V ^8  d   QhRRRR/# r0   objr   r8   rV   r9   )r:   s   "r;   r<   r=   I        &8 T r>   c                	   "   R # 5irr   r9   r@   r   s   &&r;   wait_readableAsyncBackend.wait_readableG  r   r[   c                    V ^8  d   QhRRRR/# r   r9   )r:   s   "r;   r<   r=   N  r   r>   c                	   "   R # 5irr   r9   r   s   &&r;   wait_writableAsyncBackend.wait_writableL  r   r[   c                    V ^8  d   QhRRRR/# r   r9   )r:   s   "r;   r<   r=   S  s      !3  r>   c                	    R # rr   r9   r   s   &&r;   notify_closingAsyncBackend.notify_closingQ  r|   r>   c                    V ^8  d   QhRRRR/# r   r9   )r:   s   "r;   r<   r=   X  s      f  r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_listener_socket!AsyncBackend.wrap_listener_socketV  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r#   r9   )r:   s   "r;   r<   r=   ]  s      F | r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_stream_socketAsyncBackend.wrap_stream_socket[  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r&   r9   )r:   s   "r;   r<   r=   b  s       <L r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_unix_stream_socket$AsyncBackend.wrap_unix_stream_socket`  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r$   r9   )r:   s   "r;   r<   r=   g  s       I r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_udp_socketAsyncBackend.wrap_udp_sockete  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r   r9   )r:   s   "r;   r<   r=   l        6 >P r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_connected_udp_socket&AsyncBackend.wrap_connected_udp_socketj  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r%   r9   )r:   s   "r;   r<   r=   q  r  r>   c                	   "   R # 5irr   r9   r   s   &&r;   wrap_unix_datagram_socket&AsyncBackend.wrap_unix_datagram_socketo  r   r[   c                    V ^8  d   QhRRRR/# )r0   r   r   r8   r    r9   )r:   s   "r;   r<   r=   v  s      	$r>   c                	   "   R # 5irr   r9   r   s   &&r;   #wrap_connected_unix_datagram_socket0AsyncBackend.wrap_connected_unix_datagram_sockett  r   r[   c                   V ^8  d   QhRR/# )r0   r8   r   r9   )r:   s   "r;   r<   r=   }  s       r>   c                	    R # rr   r9   rG   s   &r;   current_default_thread_limiter+AsyncBackend.current_default_thread_limiter{  r|   r>   c                    V ^8  d   QhRRRR/# )r0   signalsr   r8   z.AbstractContextManager[AsyncIterator[Signals]]r9   )r:   s   "r;   r<   r=     s      	7r>   c                	    R # rr   r9   )r@   r"  s   &*r;   open_signal_receiver!AsyncBackend.open_signal_receiver  rt   r>   c                   V ^8  d   QhRR/# )r0   r8   r   r9   )r:   s   "r;   r<   r=     s       r>   c                	    R # rr   r9   rG   s   &r;   get_current_taskAsyncBackend.get_current_task  r|   r>   c                   V ^8  d   QhRR/# )r0   r8   zSequence[TaskInfo]r9   )r:   s   "r;   r<   r=     s      "4 r>   c                	    R # rr   r9   rG   s   &r;   get_running_tasksAsyncBackend.get_running_tasks  r|   r>   c                   V ^8  d   QhRR/# rU   r9   )r:   s   "r;   r<   r=     s      T r>   c                	   "   R # 5irr   r9   rG   s   &r;   wait_all_tasks_blocked#AsyncBackend.wait_all_tasks_blocked  r   r[   c                    V ^8  d   QhRRRR/# )r0   r7   r6   r8   r)   r9   )r:   s   "r;   r<   r=     s       J r>   c                	    R # rr   r9   )r@   r7   s   &&r;   create_test_runnerAsyncBackend.create_test_runner  r|   r>   r9   )FNrr   )r   )7__name__
__module____qualname____firstlineno__classmethodr   rA   rH   rN   rR   rX   ra   rh   rg   r_   r`   rf   r^   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  r  r  r  r$  r(  r,  r0  r4  __static_attributes__r9   r>   r;   r.   r.   2   sf     (       U  U    	# 	# 	 	    "&((;@  
 
  
           !%	
 #                  	  	      
             !  ! *  *   
 
 '( "#    (   
                              
      
            r>   r.   )	metaclass)      )B__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_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   bytesr,   __annotations__r.   )r?  s   @r;   <module>rT     s    " "  
 ' H H -   4 4  w++6,PP*)	 	 	 '!$:
#%K(3-7(5/I	 IgW gr>   