vKgSSKJr SSKrSSKJr SSKJr SSKJr SSK r SSK J r J r J r \(aSSKJrJrJrJr SS KJr SS KJr \SS j5r"S S 5rSSjr\SSj5rg)) annotationsN) OrderedDict)contextmanager) TYPE_CHECKING)ConflictDetectoris_main_thread signal_raise) AsyncIteratorCallable GeneratorIterable) FrameType)Selfc#4# 0n[U5Hn[R"X15X#'M Sv UR5Hup4[R"X45 M g!UR5Hup4[R"X45 M f=f7fN)setsignalitems)signalshandleroriginal_handlerssignumoriginal_handlers M/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/trio/_signals.py_signal_handlerr6s| 4'lF(. f(F  %# (9(?(?(A $F MM& 3)B(9(?(?(A $F MM& 3)BsB.A$0B$1BBcF\rSrSrS SjrS SjrS SjrS SjrS SjrSr g) SignalReceiverEc[5Ul[RR 5Ul[ S5UlSUlg)Nz8only one task can iterate on a signal receiver at a timeF) r_pendingtriolowlevel ParkingLot_lotr_conflict_detector_closedselfs r__init__SignalReceiver.__init__Fs80;  MM,,. "2 F#  cUR(a [U5 gSURU'URR 5 gr)r'r r!r%unpark)r)rs r_addSignalReceiver._addOs/ <<  $(DMM& ! II   r,c6^^STlSUU4SjjmT"5 g)NTc>TR(a/TRRSS9up[U5 T"5 gg!T"5 f=f)NFlast)r!popitemr )r_ deliver_nextr)s rr79SignalReceiver._redeliver_remaining..deliver_next^sC}} MM11u1= # ( N  !Ns A A returnNone)r')r)r7s`@r_redeliver_remaining#SignalReceiver._redeliver_remainingVs  # # r,cU$rr(s r __aiter__SignalReceiver.__aiter__hs r,c# UR(a [S5eUR UR(d#URR 5IShvN O&[ RR5IShvN URRSS9upUsSSS5 $NQN,!,(df  g=f7f)Nz)open_signal_receiver block already exitedFr3) r' RuntimeErrorr&r!r%parkr"r# checkpointr5)r)rr6s r __anext__SignalReceiver.__anext__ks <<JK K $ $==iinn&&&mm..000 --5-9IF % $&0 % $s@)C/B0B,&B0B. B0" C,B0.B00 B>:C)r'r&r%r!Nr9)rintr:r;)r:r)r:rH) __name__ __module__ __qualname____firstlineno__r*r/r<r@rF__static_attributes__r?r,rrrEs$ r,rcZ[U[5(de[UR5$)z/Helper for tests, not public or otherwise used.) isinstancerlenr!)recs rget_pending_signal_countrRzs& c> * ** * s|| r,c'h^^# U(d [S5e[5(d [S5e[RR 5m[ 5mSUU4Sjjn[X5 Tv SSS5 TR5 g!,(df  N=f!TR5 f=f7f)aA context manager for catching signals. Entering this context manager starts listening for the given signals and returns an async iterator; exiting the context manager stops listening. The async iterator blocks until a signal arrives, and then yields it. Note that if you leave the ``with`` block while the iterator has unextracted signals still pending inside it, then they will be re-delivered using Python's regular signal handling logic. This avoids a race condition when signals arrives just before we exit the ``with`` block. Args: signals: the signals to listen for. Raises: TypeError: if no signals were provided. RuntimeError: if you try to use this anywhere except Python's main thread. (This is a Python limitation.) Example: A common convention for Unix daemons is that they should reload their configuration when they receive a ``SIGHUP``. Here's a sketch of what that might look like using :func:`open_signal_receiver`:: with trio.open_signal_receiver(signal.SIGHUP) as signal_aiter: async for signum in signal_aiter: assert signum == signal.SIGHUP reload_configuration() zNo signals were providedz]Sorry, open_signal_receiver is only possible when running in Python interpreter's main threadc<>TRTRUSS9 g)NT) idempotent) run_sync_soonr/)rframequeuetokens rr%open_signal_receiver..handlers EJJ4@r,N)rrHrWzFrameType | Noner:r;) TypeErrorr rCr"r#current_trio_tokenrrr<)rrrXrYs @@ropen_signal_receiverr]sL 233    /   MM , , .E  EAA% W .K/ ""$/ . ""$s6AB2# B.B 3B;B2 BBB//B2)rz Iterable[int]rzHCallable[[int, FrameType | None], object] | int | signal.Handlers | Noner:zGenerator[None, None, None])rQzAsyncIterator[int]r:rH)rzsignal.Signals | intr:z)Generator[AsyncIterator[int], None, None]) __future__rr collectionsr contextlibrtypingrr"_utilrr r collections.abcr r r rtypesrtyping_extensionsrrrrRr]r?r,rrfs" #% AALL&L 4  4 U 4! 4 422j7%"7%.7%7%r,