j UddlZddlZddlZddlZddlm Z ddl m Z ddlmZdZej"edfed<ej(Zej,d ZGd d e eZ d e fd Zej2r^edddej4ej6ej6efdej8ej:ge fdej8ed efdZnedddZded dfdZ dZ!ejDdddkree!z Zded ej6fdZ#y)N)includesLoop) __version__)new_event_looprun.__all___Tc eZdZy)rN)__name__ __module__ __qualname__V/var/www/html/streamforge-license/venv/lib/python3.12/site-packages/uvloop/__init__.pyrrsrrreturnctS)zReturn a new event loop.rrrrrrs 6Mr loop_factorydebugmainrrcy)5The preferred way of running a coroutine with uvloop.Nr)rrrs rr r src fd}tjdd}|dkrtj t dtj st dj|} tj|||j||j| t||j|jt|dr|j|jtjd|jS|dk(rWtj t dtj d ||d |5}|j#|cdddS|d k\sJtj"|f||d |S#tjd|jwxYw# t||j|jt|dr|j|jtjd|jw#tjd|jwxYwxYw#1swYyxYw) rcKtj}t|ts t dd{S7w)Nz)uvloop.run() uses a non-uvloop event loop) __asyncio_get_running_loop isinstancer TypeError)looprs rwrapperzrun..wrapper)s7..0DdD) KLL: :s 5?=?N) 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_kwargsr"vir!runners` rr r &s\   r " =**,8"NPP((. 8??E >D !((.$NN5)..wy9 !%d+++D,C,C,EFt%@A// ::<,,T2JJL 7]**,8"NPP!!) -zz'),  - -= === )  #,,T2JJL !%d+++D,C,C,EFt%@A// ::<,,T2JJL,,T2JJL - -s>6=G4AF0+J0'GJAI1&J'I>>JJ r!cBtj|}|sy|D]}|j|jtj|ddi|D]G}|j r|j %|jd|j |dIy)Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptiontask)r all_taskscancelr2gather cancelledr>call_exception_handler)r! to_cancelr?s rr3r3hs##D)I   )>   >>  '  ' 'N!^^-)  r)installEventLoopPolicyr#r$namec|tvrtd|dtjdddk\rtd|dddld fd }Gfdd t t d |td <td <t|S) Nz"module 'uvloop' has no attribute ''r#rHz;' (it was removed in Python 3.16, use uvloop.run() instead)rctjdddk\rtjdtdt j y)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+ _warningswarnDeprecationWarningrset_event_loop_policy)rGsrrFz__getattr__..installsD   Ra G + NN-"   ''(9:rceZdZdZdefdZejr,dejfdZ dejdejfdZ GddWjZ dd Zdeffd Zd ej"edd fd ZdefdZy )$__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() rctSN)rselfs r _loop_factoryz2__getattr__..EventLoopPolicy._loop_factorys !# #rcyrVrrWs rget_child_watcherz6__getattr__..EventLoopPolicy.get_child_watchersrwatchercyrVr)rXr\s rset_child_watcherz6__getattr__..EventLoopPolicy.set_child_watchersrc6eZdZUdZej eed<y)+__getattr__..EventLoopPolicy._LocalN_loop)r rrra_typingOptional_AbstractEventLoop__annotations__rrr_Localr`s:>E7##$67 >rrfNc.|j|_yrV)rf_localrWs r__init__z-__getattr__..EventLoopPolicy.__init__s++-DKrc|jj&tdjjz|jjS)z~Get 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.)rhrar,current_threadrJ)rX threadings rget_event_loopz3__getattr__..EventLoopPolicy.get_event_loopsN {{  ("B..0556 ;;$$ $rr!c|2t|ts"tdt|jd||j _y)zSet the event loop.Nz.EventLoopPolicy.set_event_loopsK 49K(L J//03!%DKK rc"|jS)zvCreate a new event loop. You must call set_event_loop() to make this the current event loop. )rYrWs rrz3__getattr__..EventLoopPolicy.new_event_loops %%' 'rrN)r rr__doc__rrYrb TYPE_CHECKINGNoReturnr[Anyr^localrfrirdrmrcr0r)rlsrrGrTs  $4 $   7+;+;  &{{ !!   ?Y__ ? ( %$6 % %(();< %  % (D (rrGAbstractEventLoopPolicyrFrq)_deprecated_namesAttributeErrorr*r+rlgetattrrglobals)rJrFrGrls @@r __getattr__r|s $$A$qIJJ  2A ' )07H I   ;C( 45C(J#GIi#2GI 9T?r)$asynciortypingrbsysr*warningsrOr __includesr!r __BaseLoop_versionrr TuplestrreAbstractEventLooprdTypeVarr rrs CoroutinerurcCallableboolr r3rxr+r|rrrrsV$$!$=sCx <00W__T :)    &* D W[[" <=D&&   RX & D % D D#1?D.423Ra7"   Gacagkkar