U $i@s,UddlZddlZddlZddlZddlm Z ddl m Z ddlmZdZejedfed<ejZed ZGd d d e eZ e d d dZejreddejejejefejejge fejeedddZneddddZeddddZ dZ!ej"dddkree!7ZeejdddZ#dS)N)includesLoop) __version__)new_event_looprun.__all___Tc@s eZdZdS)rN)__name__ __module__ __qualname__rr3/tmp/pip-unpacked-wheel-6lmrvi0o/uvloop/__init__.pyrsrreturncCstS)zReturn a new event loop.rrrrrrsr loop_factorydebug)mainrrrcCsdS)5The preferred way of running a coroutine with uvloop.Nr)rrrrrrrsrc sPfdd}tjdd}|dkrtdk r6tdtsNtd|}z,t||dk rr||| |WSz2t || | t |dr| |W5td| XXn~|d kr$tdk rtdtjf||d |}||W5QRSQRXn(|d ks2ttj|f||d |SdS) 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 )_sys version_inforr RuntimeError iscoroutine ValueErrorformatset_event_loopclose_cancel_all_tasksrun_until_completeZshutdown_asyncgenshasattrr!Z set_debugZRunnerrAssertionError)rrrZ run_kwargsrvirrunnerrrrr&s`          rrcCstt|}|sdS|D] }|q|tj|ddi|D]0}|rLq>|dk r>|d||dq>dS)NZreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptiontask)rZ all_taskscancelr.ZgatherZ cancelledr5Zcall_exception_handler)rZ to_cancelr6rrrr-hs"   r-)installEventLoopPolicyrr)namercs|tkrtd|dn"tjdddkr.installcseZdZdZedddZejrDejdddZ ej ejddd Z Gd d d j Z d dd dZedfdd Zejed dddZedddZd 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() rcSstSN)rselfrrr _loop_factorysz2__getattr__..EventLoopPolicy._loop_factorycSsdSrBrrCrrrget_child_watchersz6__getattr__..EventLoopPolicy.get_child_watcher)watcherrcSsdSrBr)rDrGrrrset_child_watchersz6__getattr__..EventLoopPolicy.set_child_watcherc@s eZdZUdZejeed<dS)z+__getattr__..EventLoopPolicy._LocalN_loop)r r r rI_typingOptional_AbstractEventLoop__annotations__rrrr_Locals rNNcSs||_dSrB)rN_localrCrrr__init__sz-__getattr__..EventLoopPolicy.__init__cs&|jjdkrtdj|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.)rOrIr'current_threadr<rC threadingrrget_event_loops z3__getattr__..EventLoopPolicy.get_event_loopr3cSs4|dk r(t|ts(tdt|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. )rErCrrrrsz3__getattr__..EventLoopPolicy.new_event_loop)r r r __doc__rrErJ TYPE_CHECKINGNoReturnrFAnyrHlocalrNrPrLrTrKr+rrrRrrr9s   r9ZAbstractEventLoopPolicyr8)_deprecated_namesAttributeErrorr%r&rSgetattrrglobals)r<r8r)r9rSr __getattr__s E  r_)$ZasynciortypingrJsysr%warningsr?rZ __includesrrZ __BaseLoop_versionrr TuplestrrMZAbstractEventLooprLTypeVarr rrW CoroutinerYrKCallableboolrr-r[r&r_rrrrs:      B