jj#dZddlmZddlZddlZddlZddlZddlZddlm Z m Z ejr,ddl m Z ddlmZddlmZed Zej&d Zd ZGd d e Zy)z-Asyncio based urwid EventLoop implementation.) annotationsN) EventLoop ExitMainLoop)Callable)Executor) ParamSpec_Spec_T)AsyncioEventLoopceZdZdZdddfdZddZddZddZ ddZdd Z dd Z dd Z dd Z dd Z ddZddZddZxZS)r a Event loop based on the standard library ``asyncio`` module. .. warning:: Under Windows, AsyncioEventLoop globally enforces WindowsSelectorEventLoopPolicy as a side-effect of creating a class instance. Original event loop policy is restored in destructor method. .. note:: If you make any changes to the urwid state outside of it handling input or responding to alarms (for example, from asyncio.Task running in background), and wish the screen to be redrawn, you must call :meth:`MainLoop.draw_screen` method of the main loop manually. A good way to do this: asyncio.get_event_loop().call_soon(main_loop.draw_screen) N)loopc t|tjtj |j j|_tjdddkrd|_ d|_ |r||_ ntj|_ tjdk(rnt!|jtj"sJ|jj%dtj&tj"d|_ nd|_ tj(|_ n+d|_|r||_ n tj,|_ d|_d|_d|_i|_y#t.$rKtj0tj2|_|j*j5|_ YpwxYw) N Fwin32z?Set WindowsSelectorEventLoopPolicy as asyncio event loop policyT) loop_factoryr)super__init__logging getLogger__name__getChild __class__loggersys version_info_event_loop_policy_altered_original_event_loop_policy_loopasyncioget_event_loop_policyplatform isinstanceWindowsSelectorEventLoopPolicydebugset_event_loop_policyget_event_loop_runnerget_running_loop RuntimeErrorRunnerSelectorEventLoopget_loop_exc_idle_asyncio_handle _idle_handle_idle_callbacks)selfrkwargsrs f/home/ubuntu/.cache/pipx/cdb5059130eadca/lib/python3.12/site-packages/urwid/event_loop/asyncio_loop.pyrzAsyncioEventLoop.__init__Bsn ''1::4>>;R;RS   BQ ' )49D +W[D ,8< 3:3P3P3R0<<7*:44g6\6\4KK%%&gh11>>@7;D36;D3$335 37DL8< 9!(!9!9!;DJ +/ @D!!"DF$9#*>>w?X?X#YDL!%!6!6!8DJ9s FAGGctjdddkr-|jr tj|j yy|j |j jyy)Nrr)rrr r#r)r!r+close)r5s r7__del__zAsyncioEventLoop.__del__msX   BQ ' )..--d.N.NO/ \\ % LL   &cHtjdfd }|S)z@ Wrap the callback to also call _entering_idle. cjs+jjdj_|i|S)Nr)r2r" call_later_entering_idle)argsr6callbackr5s r7wrapperz1AsyncioEventLoop._also_call_idle..wrapperys;,,,0JJ,A,A!TEXEX,Y)T,V, ,r;)r@ _Spec.argsr6 _Spec.kwargsreturnr ) functoolswraps)r5rArBs`` r7_also_call_idlez AsyncioEventLoop._also_call_idlets'  " - # - r;cz |jjD] }|  d|_y#d|_wxYw)z9 Call all the registered idle callbacks. N)r4valuesr2r5rAs r7r?zAsyncioEventLoop._entering_idles= - 00779   )-D %D %s&1 :ch|jj|tj|g|i|S)a$Run callable in executor. :param executor: Executor to use for running the function. Default asyncio executor is used if None. :type executor: concurrent.futures.Executor | None :param func: function to call :type func: Callable :param args: arguments to function (positional only) :type args: object :param kwargs: keyword arguments to function (keyword only) :type kwargs: object :return: future object for the function call outcome. :rtype: asyncio.Future )r"run_in_executorrFpartial)r5executorfuncr@r6s r7rMz AsyncioEventLoop.run_in_executors1(zz))(I4E4Ed4\T4\U[4\]]r;cX|jj||j|S)a Call callback() a given time from now. No parameters are passed to callback. Returns a handle that may be passed to remove_alarm() seconds -- time in seconds to wait before calling callback callback -- function to call from event loop )r"r>rH)r5secondsrAs r7alarmzAsyncioEventLoop.alarms&zz$$Wd.B.B8.LMMr;cH|j }|j|S)z] Remove an alarm. Returns True if the alarm exists, False otherwise ) cancelledcancel)r5handleexisteds r7 remove_alarmzAsyncioEventLoop.remove_alarms# &&(( r;c\|jj||j||S)a" Call callback() when fd has some data to read. No parameters are passed to callback. Returns a handle that may be passed to remove_watch_file() fd -- file descriptor to watch for input callback -- function to call when input is available )r" add_readerrH)r5fdrAs r7 watch_filezAsyncioEventLoop.watch_files( b$"6"6x"@A r;c8|jj|S)zg Remove an input file. Returns True if the input file exists, False otherwise )r" remove_readerr5rWs r7remove_watch_filez"AsyncioEventLoop.remove_watch_files zz''//r;cv|xjdz c_||j|j<|jS)zw Add a callback for entering idle. Returns a handle that may be passed to remove_enter_idle() r)r3r4rKs r7 enter_idlezAsyncioEventLoop.enter_idles7 Q2:T../   r;c> |j|=y#t$rYywxYw)z[ Remove an idle callback. Returns True if the handle was removed. FT)r4KeyErrorr`s r7remove_enter_idlez"AsyncioEventLoop.remove_enter_idles.  $$V,  s  c|jdx}rV|j|jr!|jjd|_t |t s||_yy|j|y)N exception)getstopr2rVr&rr1default_exception_handler)r5rcontextexcs r7_exception_handlerz#AsyncioEventLoop._exception_handlersj++k* *3 * IIK(())002,0)c<0 1  * *7 3r;c|jj|j|jj|jr.|j}d|_|j |j y)zStart the event loop. Exit the loop when any callback raises an exception. If ExitMainLoop is raised, exit cleanly. N)r"set_exception_handlerrn run_foreverr1with_traceback __traceback__)r5rms r7runzAsyncioEventLoop.runs_ (()@)@A  99))CDI$$S%6%67 7 r;)rz asyncio.AbstractEventLoop | NonerENone)rEru)rACallable[_Spec, _T]rErv) rOzExecutor | NonerPrvr@rCr6rDrEzasyncio.Future[_T])rRfloatrACallable[[], typing.Any]rEzasyncio.TimerHandle)rEbool)r\intrArxrErz)rWrzrEry)rArxrErz)rzasyncio.AbstractEventLoop)r __module__ __qualname____doc__rr:rHr?rMrSrYr]rarcrfrnrt __classcell__)rs@r7r r .s&DH)GV! -^!^"^ ^  ^  ^, N 0 ! 4 8r;r )r} __future__rr#rFrrtyping abstract_looprr TYPE_CHECKINGcollections.abcrconcurrent.futuresrtyping_extensionsr r TypeVarr __all__r r;r7rs^,4" 2 (++ g E  B Q8yQ8r;