U <{fl@sddlZddlZddlZddlZddlm Z ddl m Z ddlmZddlmZdZedZGd d d eejZed d d Zdd ddZejreddejejejefejejgefejeedddZneddddZejddddZ Gddde Z!dS)N)BaseDefaultEventLoopPolicy)includesLoop) __version__)new_event_loopinstallEventLoopPolicy_Tc@s eZdZdS)rN)__name__ __module__ __qualname__rrN/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/uvloop/__init__.pyrsrreturncCstS)zReturn a new event loop.rrrrrrsrcCs2tjdddkr"tjdtddttdS)z+A helper function to install uvloop policy.N zRuvloop.install() is deprecated in favor of uvloop.run() starting with Python 3.12.r) stacklevel)_sys version_info _warningswarnDeprecationWarning __asyncioset_event_loop_policyr rrrrr sr  loop_factorydebug)mainr r!rcCsdS)5The preferred way of running a coroutine with uvloop.Nr)r"r r!rrrrun)sr$c sPfdd}tjdd}|dkrtdk r6tdtsNtd|}z,t||dk rr||| |WSz2t || | t |dr| |W5td| XXn~|d kr$tdk rtdtjf||d |}||W5QRSQRXn(|d ks2ttj|f||d |SdS) r#cs$t}t|tstdIdHS)Nz)uvloop.run() uses a non-uvloop event loop)r_get_running_loop isinstancer TypeError)loopr"rrwrapper6s zrun..wrapperNr)r z8asyncio.run() cannot be called from a running event loopz"a coroutine was expected, got {!r}shutdown_default_executor)r rr)rrrr% RuntimeError iscoroutine ValueErrorformatset_event_loopclose_cancel_all_tasksrun_until_completeshutdown_asyncgenshasattrr, set_debugZRunnerr$AssertionError)r"r r!Z run_kwargsr*vir(runnerrr)rr$3s`          )r(rcCstt|}|sdS|D] }|q|tj|ddi|D]0}|rLq>|dk r>|d||dq>dS)Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptiontask)r all_taskscancelr5gather cancelledr>call_exception_handler)r( to_cancelr?rrrr4us"   r4c@sHeZdZdZedddZejrDejdddZ ej ejddd Z d S) r aEvent loop policy. The preferred way to make your application use uvloop: >>> import asyncio >>> import uvloop >>> asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) >>> asyncio.get_event_loop() rcCstSN)rselfrrr _loop_factoryszEventLoopPolicy._loop_factorycCsdSrFrrGrrrget_child_watchersz!EventLoopPolicy.get_child_watcher)watcherrcCsdSrFr)rHrKrrrset_child_watchersz!EventLoopPolicy.set_child_watcherN) r r r__doc__rrI_typing TYPE_CHECKINGNoReturnrJAnyrLrrrrr s r )"asynciortypingrNsysrwarningsrZasyncio.eventsrZ __BasePolicyrZ __includesr(rZ __BaseLoop_versionr__all__TypeVarr AbstractEventLooprr rO CoroutinerQOptionalCallableboolr$r4r rrrrs4        B