o 0 i @s4UddlZddlZddlZddlZddlm Z ddl m Z ddlmZdZejedfed<ejZed ZGd d d e eZ d e fd dZejrnedddejejejefdejejge fdejed efddZneddddZded dfddZ dZ!ej"dddkree!7Zded ejfddZ#dS)N)includesLoop) __version__)new_event_looprun.__all___Tc@s eZdZdS)rN)__name__ __module__ __qualname__rr[/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/uvloop/__init__.pyrsrreturncCtS)zReturn a new event loop.rrrrrrsr loop_factorydebugmainrrcCsdS)5The preferred way of running a coroutine with uvloop.Nr)rrrrrrrsrc sfdd}tjdd}|dkrtdurtdts'td|}zLt||dur9| || |Wz-t || | t |drb| |Wtd|SWtd|Std|wz-t || | t |dr| |Wtd|wWtd|wtd|w|d krtdurtdtjd ||d |}||WdS1swYdS|d ksJtj|f||d |S) rcs&t}t|tstdIdHS)Nz)uvloop.run() uses a non-uvloop event loop) __asyncio_get_running_loop isinstancer TypeError)looprrrwrapper)s   zrun..wrapperN) z8asyncio.run() cannot be called from a running event loopz"a coroutine was expected, got {!r}shutdown_default_executor)r rr r)_sys version_inforr RuntimeError iscoroutine ValueErrorformatset_event_loop set_debugrun_until_complete_cancel_all_tasksshutdown_asyncgenshasattrr!closeZRunnerr)rrrZ run_kwargsrvirrunnerrrrr&s                     $ rcCstt|}|s dS|D]}|q |tj|ddi|D]}|r&q|dur7|d||dqdS)Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptiontask)r all_taskscancelr-gather cancelledr6call_exception_handler)r to_cancelr7rrrr.hs&   r.)installEventLoopPolicyrrnamecs|tvr td|dtjdddkrtd|dddldfdd }Gfd d d ttd |td <td <t|S)Nz"module 'uvloop' has no attribute ''rr@z;' (it was removed in Python 3.16, use uvloop.run() instead)rrcs2tjdddkrtjdtddtdS)zA helper function to install uvloop policy. This function is deprecated and will be removed in Python 3.16. Use `uvloop.run()` instead. Nrr#zRuvloop.install() is deprecated in favor of uvloop.run() starting with Python 3.12.r) stacklevel)r%r& _warningswarnDeprecationWarningrset_event_loop_policyr)r?rrr>sz__getattr__..installcseZdZdZdefddZejr#dejfddZ dej dejfdd Z Gd d d j Z dd dZdeffdd Zdejedd fddZdefddZd S)z$__getattr__..EventLoopPolicyalEvent 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() rcSrN)rselfrrr _loop_factorysz2__getattr__..EventLoopPolicy._loop_factorycSdSrIrrJrrrget_child_watchersz6__getattr__..EventLoopPolicy.get_child_watcherwatchercSrMrIr)rKrOrrrset_child_watchersz6__getattr__..EventLoopPolicy.set_child_watcherc@s eZdZUdZejeed<dS)z+__getattr__..EventLoopPolicy._LocalN_loop)r r r rQ_typingOptional_AbstractEventLoop__annotations__rrrr_Locals rVNcSs||_dSrI)rV_localrJrrr__init__sz-__getattr__..EventLoopPolicy.__init__cs&|jjdurtdj|jjS)z~Get the event loop for the current context. Returns an instance of EventLoop or raises an exception. Nz,There is no current event loop in thread %r.)rWrQr'current_threadrBrJ threadingrrget_event_loops z3__getattr__..EventLoopPolicy.get_event_looprcSs4|durt|tstdt|jd||j_dS)zSet the event loop.Nz.EventLoopPolicy.set_event_loopcSs|S)zvCreate a new event loop. You must call set_event_loop() to make this the current event loop. )rLrJrrrrsz3__getattr__..EventLoopPolicy.new_event_looprN)r r r __doc__rrLrR TYPE_CHECKINGNoReturnrNAnyrPlocalrVrXrTr\rSr+rrrZrrr?s&      r?AbstractEventLoopPolicyr>r^)_deprecated_namesAttributeErrorr%r&r[getattrrglobals)rBr>r)r?r[r __getattr__s  E  ri)$asynciortypingrRsysr%warningsrErZ __includesrrZ __BaseLoop_versionrr TuplestrrUAbstractEventLooprTTypeVarr rr` CoroutinerbrSCallableboolrr.rer&rirrrrs@        B