grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a Bjj$@s$ddlmZmZGdddeZdS)) EventLoop ExitMainLoopc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZddZddZd d!Zd"S)# TrioEventLoopzn Event loop based on the ``trio`` module. ``trio`` is an async library for Python 3.5 and later. cCs<ddl}d|_i|_g|_||_d|_|j|_|jj |_ dS)z Constructor.N) trio _idle_handle_idle_callbacks_pending_tasks_trio_nurserysleep_sleephazmatZ wait_readable_wait_readable)selfrr@/usr/lib64/python3.9/site-packages/urwid/_async_kw_event_loop.py__init__ szTrioEventLoop.__init__cCs||j||S)aLCalls `callback()` a given time from now. No parameters are passed to the callback. Parameters: seconds: time in seconds to wait before calling the callback callback: function to call from the event loop Returns: a handle that may be passed to `remove_alarm()` ) _start_task _alarm_task)rsecondscallbackrrralarm.s zTrioEventLoop.alarmcCs |jd7_||j|j<|jS)zCalls `callback()` when the event loop enters the idle state. There is no such thing as being idle in a Trio event loop so we simulate it by repeatedly calling `callback()` with a short delay. r)rr)rrrrr enter_idle;s zTrioEventLoop.enter_idlecCs ||S)zeRemoves an alarm. Parameters: handle: the handle of the alarm to remove  _cancel_scoperZhandlerrr remove_alarmEszTrioEventLoop.remove_alarmcCs&z |j|=Wnty YdS0dS)zuRemoves an idle callback. Parameters: handle: the handle of the idle callback to remove FT)rKeyErrorrrrrremove_enter_idleMs   zTrioEventLoop.remove_enter_idlecCs ||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 rrrrrremove_watch_fileYs zTrioEventLoop.remove_watch_filecCs|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)rscopeZexistedrrrrdszTrioEventLoop._cancel_scopecsn|jGfddd|jjj}|}|jj|j$|jj|j|gdWdn1s`0YdS)zStarts the event loop. Exits the loop when any callback raises an exception. If ExitMainLoop is raised, exits cleanly. cseZdZfddZdS)z5TrioEventLoop.run..TrioIdleCallbackInstrumentcs |dkrD] }|qdSNrvaluesrtimeoutZ idle_callbackZidle_callbacksrrbefore_io_waitzs zDTrioEventLoop.run..TrioIdleCallbackInstrument.before_io_waitN__name__ __module__ __qualname__r*rr)rrTrioIdleCallbackInstrumentysr/)Z instrumentsN) rr abc Instrument MultiErrorcatch_handle_main_loop_exceptionrun _main_taskrr/Zemulate_idle_callbacksrr)rr5os zTrioEventLoop.runc s|jGfddd|jjj}|}|jj|jP|jj|z | IdHW|jj |n|jj |0Wdn1s0YdS)aStarts the main loop and blocks asynchronously until the main loop exits. This allows one to embed an urwid app in a Trio app even if the Trio event loop is already running. Example:: with trio.open_nursery() as nursery: event_loop = urwid.TrioEventLoop(nursery=nursery) loop = urwid.MainLoop(widget, event_loop=event_loop) with loop.start(): await event_loop.run_async() cseZdZfddZdS)z;TrioEventLoop.run_async..TrioIdleCallbackInstrumentcs |dkrD] }|qdSr$r%r'r)rrr*s zJTrioEventLoop.run_async..TrioIdleCallbackInstrument.before_io_waitNr+rr)rrr/sr/N) rr r0r1r2r3r4rZadd_instrumentr6Zremove_instrumentr7rr)r run_asyncs zTrioEventLoop.run_asynccCs||j||S)abCalls `callback()` when the given file descriptor has some data to read. No parameters are passed to the callback. Parameters: fd: file descriptor to watch for input callback: function to call when some input is available Returns: a handle that may be passed to `remove_watch_file()` )r _watch_task)rfdrrrr watch_files zTrioEventLoop.watch_filecs>|&||IdH|Wdn1s00YdS)a0Asynchronous task that sleeps for a given number of seconds and then calls the given callback. Parameters: scope: the cancellation scope that can be used to cancel the task seconds: the number of seconds to wait callback: the callback to call N)r )rr#rrrrrrs zTrioEventLoop._alarm_taskcCs |jt|trdS|SdS)a=Handles exceptions raised from the main loop, catching ExitMainLoop instead of letting it propagate through. Note that since Trio may collect multiple exceptions from tasks into a Trio MultiError, we cannot simply use a try..catch clause, we need a helper function like this. N)rclear isinstancer)rexcrrrr4s  z)TrioEventLoop._handle_main_loop_exceptionc spzb|j4IdH0|_||jIdHWdIdHqZ1IdHsP0YWd|_nd|_0dS)zzMain Trio task that opens a nursery and then sleeps until the user exits the app by raising ExitMainLoop. N)r Z open_nurseryr _schedule_pending_tasksZ sleep_forever)rrrrr6s <zTrioEventLoop._main_taskcCs8|jD] \}}}|jj||g|Rq|jdd=dS)zSchedules all pending asynchronous tasks that were created before the nursery to be executed on the nursery soon. N)r r start_soon)rtaskr#argsrrrr?sz%TrioEventLoop._schedule_pending_taskscGs>|j}|jr(|jj||g|Rn|j|||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 Z CancelScoper r@r append)rrArBr#rrrrs zTrioEventLoop._start_taskcsF|.|js$||IdH|qWdn1s80YdS)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)rr#r:rrrrr9s zTrioEventLoop._watch_taskN)r,r-r.__doc__rrrrrr rr5r8r;rr4r6r?rr9rrrrrs"         rN)Z main_looprrrrrrrs