
    k*i              	       6   % S SK rS SKrS SKrS SKrSSKJ	r
  SSKJr  SSKJr  Sr\R"                  \S4   \S'   \R(                  r\R,                  " S	5      r " S
 S\\5      rS\4S jr\R2                  (       a`  \SS.S\R4                  \R6                  \R6                  \4   S\R8                  \R:                  / \4      S\R8                  \   S\4S jjrO\SS.S jrS\SS4S jr Sr!\RD                  SS S:  a  \\!-  rS\S\R6                  4S jr#g)    N   )includesLoop)__version__)new_event_looprun.__all___Tc                       \ rS rSrSrg)r       N)__name__
__module____qualname____firstlineno____static_attributes__r       O/var/www/html/land-doc-ocr/venv/lib/python3.13/site-packages/uvloop/__init__.pyr   r      s    r   r   returnc                      [        5       $ )zReturn a new event loop.r   r   r   r   r   r      s	    6Mr   loop_factorydebugmainr   r   c                    g)5The preferred way of running a coroutine with uvloop.Nr   )r   r   r   s      r   r	   r	      s    r   c                j  ^  U 4S jn[         R                  SS nUS::  Ga  [        R                  " 5       b  [	        S5      e[        R
                  " T 5      (       d  [        SR                  T 5      5      eU" 5       n [        R                  " U5        Ub  UR                  U5        UR                  U" 5       5       [        U5        UR                  UR                  5       5        [        US5      (       a  UR                  UR                  5       5        [        R                  " S5        UR                  5         $ US:X  aZ  [        R                  " 5       b  [	        S5      e[        R                   " SUUS	.UD6 nUR#                  U" 5       5      sSSS5        $ US
:  d   e[        R"                  " U" 5       4UUS	.UD6$ ! [        R                  " S5        UR                  5         f = f!  [        U5        UR                  UR                  5       5        [        US5      (       a  UR                  UR                  5       5        [        R                  " S5        UR                  5         f ! [        R                  " S5        UR                  5         f = f= f! , (       d  f       g= f)r   c                     >#    [         R                  " 5       n [        U [        5      (       d  [	        S5      eTI S h  vN $  N7f)Nz)uvloop.run() uses a non-uvloop event loop)	__asyncio_get_running_loop
isinstancer   	TypeError)loopr   s    r   wrapperrun.<locals>.wrapper)   s9      ..0DdD)) KLL::s   ;AAAN   )   
   z8asyncio.run() cannot be called from a running event loopz"a coroutine was expected, got {!r}shutdown_default_executor)r(      r   r(      r   )_sysversion_infor    r!   RuntimeErroriscoroutine
ValueErrorformatset_event_loop	set_debugrun_until_complete_cancel_all_tasksshutdown_asyncgenshasattrr*   closeRunnerr	   )r   r   r   
run_kwargsr%   vir$   runners   `       r   r	   r	   &   s`   	 r"= **,8"NP P ((.. 8??E   >D!((.$NN5)..wy9	!%d+++D,C,C,EFt%@AA// ::< ,,T2JJL7]**,8"NP P !! )  zz'),  = ===	) 	 # ,,T2JJL	!%d+++D,C,C,EFt%@AA// ::< ,,T2JJL ,,T2JJL s>    ?G3  AGJ$(G03J!5AI6'J!6(JJ!$
J2r$   c                 h   [         R                  " U 5      nU(       d  g U H  nUR                  5         M     U R                  [         R                  " USS065        U HP  nUR                  5       (       a  M  UR                  5       c  M-  U R                  SUR                  5       US.5        MR     g )Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message	exceptiontask)r    	all_taskscancelr6   gather	cancelledrB   call_exception_handler)r$   	to_cancelrC   s      r   r7   r7   h   s     ##D)I  	)<t< >>>>'''N!^^-) 	 r   )installEventLoopPolicyr'   r(      namec                 "  ^^ U [         ;  a  [        SU  S35      e[        R                  S S S:  a  [        SU  S35      eSS KmSU4S jjn " U4S jS	[        [        S
5      5      mU[        5       S'   T[        5       S	'   [        5       U    $ )Nz"module 'uvloop' has no attribute ''r'   rL   z;' (it was removed in Python 3.16, use uvloop.run() instead)r   c                     > [         R                  SS S:  a  [        R                  " S[        SS9  [
        R                  " T " 5       5        g)zA helper function to install uvloop policy.

This function is deprecated and will be removed in Python 3.16.
Use `uvloop.run()` instead.
Nr'   r,   zRuvloop.install() is deprecated in favor of uvloop.run() starting with Python 3.12.r   )
stacklevel)r.   r/   	_warningswarnDeprecationWarningr    set_event_loop_policy)rK   s   r   rJ   __getattr__.<locals>.install   sD     Ra G+NN-"	 	''(9:r   c                   *  > \ rS rSrSrS\4S jr\R                  (       a.  S\R                  4S jr
S\R                  S\R                  4S jr " S S	 Y R                  5      rSS jrS\4U 4S jjrS\R$                  \   SS
4S jrS\4S jrSrg
)$__getattr__.<locals>.EventLoopPolicy   a,  Event loop policy for uvloop.

This class is deprecated and will be removed in Python 3.16.
Use `uvloop.run()` instead.

>>> import asyncio
>>> import uvloop
>>> asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
>>> asyncio.get_event_loop()
<uvloop.Loop running=False closed=False debug=False>
r   c                     [        5       $ N)r   selfs    r   _loop_factory2__getattr__.<locals>.EventLoopPolicy._loop_factory   s    !##r   c                     g r\   r   r]   s    r   get_child_watcher6__getattr__.<locals>.EventLoopPolicy.get_child_watcher   s    r   watcherc                     g r\   r   )r^   rd   s     r   set_child_watcher6__getattr__.<locals>.EventLoopPolicy.set_child_watcher   s     r   c                   >    \ rS rSr% Sr\R                  \   \S'   Sr	g)+__getattr__.<locals>.EventLoopPolicy._Local   N_loopr   )
r   r   r   r   rk   _typingOptional_AbstractEventLoop__annotations__r   r   r   r   _Localri      s    :>E7##$67>r   rp   Nc                 .    U R                  5       U l        g r\   )rp   _localr]   s    r   __init__-__getattr__.<locals>.EventLoopPolicy.__init__   s    ++-DKr   c                    > U R                   R                  c&  [        STR                  5       R                  -  5      eU R                   R                  $ )zfGet the event loop for the current context.

Returns an instance of EventLoop or raises an exception.
z,There is no current event loop in thread %r.)rr   rk   r0   current_threadrN   )r^   	threadings    r   get_event_loop3__getattr__.<locals>.EventLoopPolicy.get_event_loop   sN    
 {{  ("B..0556 
 ;;$$$r   r$   c                     Ub7  [        U[        5      (       d"  [        S[        U5      R                   S35      eXR
                  l        g)zSet the event loop.Nz<loop must be an instance of AbstractEventLoop or None, not 'rP   )r"   rn   r#   typer   rr   rk   )r^   r$   s     r   r4   3__getattr__.<locals>.EventLoopPolicy.set_event_loop   sL     
49K(L(L J//03  !%KKr   c                 "    U R                  5       $ )z^Create a new event loop.

You must call set_event_loop() to make this the current event loop.
)r_   r]   s    r   r   3__getattr__.<locals>.EventLoopPolicy.new_event_loop   s    
 %%''r   )rr   r   N)r   r   r   r   __doc__r   r_   rl   TYPE_CHECKINGNoReturnrb   Anyrf   localrp   rs   rn   rx   rm   r4   r   r   )rw   s   r   rK   rY      s    
		$4 	$   
7+;+; &{{!!
	?Y__ 	?	(	%$6 	%		%(();<		%		%	(D 	(r   rK   AbstractEventLoopPolicyrJ   r   )_deprecated_namesAttributeErrorr.   r/   rw   getattrr    globals)rN   rJ   rK   rw   s     @@r   __getattr__r      s    $$A$qIJJ			2A	'	)0 7H I
 	

 ;C(	45C(J #GIi#2GI 9T?r   )$asyncior    typingrl   sysr.   warningsrS    r   
__includesr$   r   
__BaseLoop_versionr   r
   Tuplestrro   AbstractEventLooprn   TypeVarr   r   r   	Coroutiner   rm   Callableboolr	   r7   r   r/   r   r   r   r   <module>r      sT       $ $ ! $=sCx	  <00  __T	:) 	 
  &*DW[[" <=D &&RX&
D %D 
D #1 ?D. 4 2 3  Ra7"  Gac agkk ar   