o Nhh @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__rrO/home/air/websocket/korean/venv/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!closeRunnerr)rrr 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 cancelledr8call_exception_handler)r to_cancelr9rrrr.hs&   r.)installEventLoopPolicyrrnamecs|tvr td|dtjdddkrtd|dddldfdd }Gfd d d ttd |td <td <t|S)Nz"module 'uvloop' has no attribute ''rrBz;' (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)rArrr@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_factorycSdSrKrrLrrrget_child_watchersz6__getattr__..EventLoopPolicy.get_child_watcherwatchercSrOrKr)rMrQrrrset_child_watchersz6__getattr__..EventLoopPolicy.set_child_watcherc@s eZdZUdZejeed<dS)z+__getattr__..EventLoopPolicy._LocalN_loop)r r r rS_typingOptional_AbstractEventLoop__annotations__rrrr_Locals rXNcSs||_dSrK)rX_localrLrrr__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.)rYrSr'current_threadrDrL 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. )rNrLrrrrsz3__getattr__..EventLoopPolicy.new_event_looprN)r r r __doc__rrNrT TYPE_CHECKINGNoReturnrPAnyrRlocalrXrZrVr^rUr+rrr\rrrAs&      rAAbstractEventLoopPolicyr@r`)_deprecated_namesAttributeErrorr%r&r]getattrrglobals)rDr@r)rAr]r __getattr__s  E  rk)$asynciortypingrTsysr%warningsrGr __includesrr __BaseLoop_versionrr TuplestrrWAbstractEventLooprVTypeVarr rrb CoroutinerdrUCallableboolrr.rgr&rkrrrrs@        B