CjSrSSKJr SSKJrJrJrJrJrJ r J r SSK J r J r SSKrSSKJr \(aSSKJr \ "S5r\ \\/\\4\\/\44r"S S \5r\R0R3S S 9"S S\\55rg)z Signals are a simple pub-sub mechanism. DOMNodes can subscribe to a signal, which will invoke a callback when the signal is published. ) annotations) TYPE_CHECKINGAny AwaitableCallableGenericTypeVarUnion)WeakKeyDictionaryrefN)log)DOMNodeSignalTc\rSrSrSrSrg) SignalErrorzRaised for Signal errors.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r`/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/textual/signal.pyrrs#rrT)angularcr\rSrSrSrS SjrS Sjr\S Sj5rSSSjjr SSjr SSjr S r g )SignalzfA signal that a widget may subscribe to, in order to invoke callbacks when an associated event occurs.cN[U5UlX l[5Ulg)zqInitialize a signal. Args: owner: The owner of this signal. name: An identifier for debugging purposes. N)r _owner_namer _subscriptions)selfownernames r__init__Signal.__init__#s$%j     rc## SUR4v SUR4v S[URR 554v g7f)Nr%r& subscriptions)r%r"listr#keysr$s r __rich_repr__Signal.__rich_repr__0sBtzz!!djj  tD$7$7$<$<$>???sA A c"UR5$)z9The owner of this Signal, or `None` if there is no owner.)r!r-s rr% Signal.owner5s{{}rc^^TR(d[STS35eU(a SU4SjjnO SUU4SjjnURRT/5nUR U5 g)aSubscribe a node to this signal. When the signal is published, the callback will be invoked. Args: node: Node to subscribe. callback: A callback function which takes a single argument and returns anything (return type ignored). immediate: Invoke the callback immediately on publish if `True`, otherwise post it to the DOM node to be called once existing messages have been processed. Raises: SignalError: Raised when subscribing a non-mounted widget. z3Node must be running to subscribe to a signal (has z been mounted)?c>T"U5 g)z Invoke the callback immediately.Nr)datacallbacks rsignal_callback)Signal.subscribe..signal_callbackTs rc*>TRTU5 g)z>Post the callback to the node, to call at the next opertunity.N) call_next)r4r5nodes rr6r7Zsx.rNr4rreturnNone) is_runningrr# setdefaultappend)r$r:r5 immediater6 callbackss `` r subscribeSignal.subscribe:sf&EdV?[      / /''224< )rc<URRUS5 g)zKUnsubscribe a node from this signal. Args: node: Node to unsubscribe, N)r#pop)r$r:s r unsubscribeSignal.unsubscribeas d+rc dUR(dgURnUcgUR(aUR(agURHnUR (aM g [ URR55HgupEUR (a"UR(aUR(aURRU5 MUUH nU"U5 M Mi g![a*n[R"SUSUSU35 SnAMDSnAff=f)zjPublish the signal (invoke subscribed callbacks). Args: data: An argument to pass to the callbacks. Nzerror publishing signal to z ignored (callback=z); ) r#r% is_attached_pruningancestors_with_selfr>r+itemsrF Exceptionr error)r$r4r% ancestor_noder:rBr5rOs rpublishSignal.publishis""   =   ENN "66M +++7 $D$7$7$=$=$?@ODOO(8(8T]]##''-!*H !* A% 9$?RS[R\\_`e_fgs*C;; D/D**D/)r"r!r#N)r%rr&strr<r=)r<zrich.repr.Result)r<zDOMNode | None)F)r:rr5zSignalCallbackType[SignalT]rAboolr<r=)r:rr<r=r;) rrrrrr'r.propertyr%rCrGrQrrrrrrs_p  @  %*%*.%* %*  %*N, rr)r __future__rtypingrrrrrr r weakrefr r rich.reprrichtextualr textual.domrrSignalCallbackTyperNrreprautorrrrr`s#SSS*# )  gY # &'7)S.)AA $)$iWW iir