;OOf'*ddlmZmZGddeZy)) EventLoop ExitMainLoopcpeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZy) TrioEventLoopzn Event loop based on the ``trio`` module. ``trio`` is an async library for Python 3.5 and later. cddl}d|_i|_g|_||_d|_|j |_ |jj|_ y#t$r|jj|_ YywxYw)z Constructor.N) trio _idle_handle_idle_callbacks_pending_tasks_trio_nurserysleep_sleeplowlevel wait_readable_wait_readableAttributeErrorhazmat)selfr s [/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/urwid/_async_kw_event_loop.py__init__zTrioEventLoop.__init__!sn!   jj  <"&--"="=D  <"&++";";D  |j|=y#t$rYywxYw)zuRemoves an idle callback. Parameters: handle: the handle of the idle callback to remove FT)r KeyErrorr%s rremove_enter_idlezTrioEventLoop.remove_enter_idleRs.  $$V,  s  c$|j|S)zRemoves a file descriptor being watched for input. Parameters: handle: the handle of the file descriptor callback to remove Returns: True if the file descriptor was watched, False otherwise r#r%s rremove_watch_filezTrioEventLoop.remove_watch_file^s!!&))rc@|j }|j|S)zCancels the given Trio cancellation scope. Returns: True if the scope was cancelled, False if it was cancelled already before invoking this function ) cancel_calledcancel)rscopeexisteds rr$zTrioEventLoop._cancel_scopeis ))) rcZ|jGfdd|jjj}|}|jjj |j 5|jj|j|gdddy#1swYyxYw)zStarts the event loop. Exits the loop when any callback raises an exception. If ExitMainLoop is raised, exits cleanly. ceZdZfdZy)5TrioEventLoop.run..TrioIdleCallbackInstrumentcJ|dkDrjD] }| yyNrvaluesrtimeout idle_callbackidle_callbackss rbefore_io_waitzDTrioEventLoop.run..TrioIdleCallbackInstrument.before_io_wait,Q;)7)>)>)@( %(rN__name__ __module__ __qualname__r=r<srTrioIdleCallbackInstrumentr4~ (rrD) instrumentsN) r r abc Instrument MultiErrorcatch_handle_main_loop_exceptionrun _main_task)rrDemulate_idle_callbacksr<s @rrLzTrioEventLoop.runts --  ()B)B ( ".TrioIdleCallbackInstrumentcJ|dkDrjD] }| yyr6r7r9s rr=zJTrioEventLoop.run_async..TrioIdleCallbackInstrument.before_io_waitr>rNr?rCsrrDrQrErrDN) r r rGrHradd_instrumentremove_instrumentrrrIrJrKrM)rrDrNrSrTr<s @r run_asynczTrioEventLoop.run_asyncs"--  ()B)B ( "K |jj4d{|_|j|jj d{dddd{d|_y7S77#1d{7swY xYw#d|_wxYww)zzMain Trio task that opens a nursery and then sleeps until the user exits the app by raising ExitMainLoop. N)r open_nurseryr_schedule_pending_tasks sleep_forever)rs rrMzTrioEventLoop._main_tasks !zz..0 1 1DM,,.jj..000 1 1!DM  10 1 1 1 1!DMssBBA6B3A<A8A< B)A:*B.B6B8A<:B<BB B B BBc|jD]$\}}}|jj||g|&|jdd=y)zSchedules all pending asynchronous tasks that were created before the nursery to be executed on the nursery soon. N)r r start_soon)rtaskr0argss rraz%TrioEventLoop._schedule_pending_taskssI"&!4!4 9 D% $DMM $ $T5 84 8 9    "rc|jj}|jr |jj||g||S|jj |||f|S)apStarts an asynchronous task in the Trio nursery managed by the main loop. If the nursery has not started yet, store a reference to the task and the arguments so we can start the task when the nursery is open. Parameters: task: a Trio task to run Returns: a cancellation scope for the Trio task )r CancelScoperrdr append)rrerfr0s rrzTrioEventLoop._start_tasksa &&( == $DMM $ $T5 84 8     & &eT': ; rcK|5|js-|j|d{||js-dddy7!#1swYyxYww)aPAsynchronous task that watches the given file descriptor and calls the given callback whenever the file descriptor becomes readable. Parameters: scope: the cancellation scope that can be used to cancel the task fd: the file descriptor to watch callback: the callback to call N)r.r)rr0rXrs rrWzTrioEventLoop._watch_tasksY ))))"--- ))    .   s+A!A AA  AA  AAN)r@rArB__doc__rrr!r'r*r,r$rLrUrYrrKrMrarrWrrrrs[ <$ E!*  * R*+:Z @   !#&rrN) main_looprrrrlrrrns./yIyr