AHjdZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z ddlZddlmZerddlmZe dZe eegeefeegeffZGd d eZej0j3d Gd deeZy)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)DOMNodeSignalTceZdZdZy) SignalErrorzRaised for Signal errors.N)__name__ __module__ __qualname____doc__F/root/tools/cai/cai_env/lib/python3.12/site-packages/textual/signal.pyrrs#rrT)angularc\eZdZdZd dZd dZed dZ d d dZddZ ddZ y)SignalzfA signal that a widget may subscribe to, in order to invoke callbacks when an associated event occurs.cPt||_||_t|_y)zInitialize a signal. Args: owner: The owner of this signal. name: An identifier for debugging purposes. N)r _owner_namer _subscriptions)selfownernames r__init__zSignal.__init__#s&%j     rc#Kd|jfd|jfdt|jj fyw)Nr!r" subscriptions)r!rlistrkeysr s r __rich_repr__zSignal.__rich_repr__0sCtzz!!djj  tD$7$7$<$<$>???sA A c"|jS)z9The owner of this Signal, or `None` if there is no owner.)rr(s rr!z Signal.owner5s{{}rcjstdd|rdfd }ndfd }|jjg}|j |y)a&Subscribe 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|y)z Invoke the callback immediately.Nr)datacallbacks rsignal_callbackz)Signal.subscribe..signal_callbackUs rc*j|y)z>Post the callback to the node, to call at the next opertunity.N) call_next)r-r.nodes rr/z)Signal.subscribe..signal_callback[sx.rNr-rreturnNone) is_runningrr setdefaultappend)r r2r. immediater/ callbackss `` r subscribezSignal.subscribe:s\(EdV?[     /''224< )rc<|jj|dy)zcUnsubscribe a node from this signal. Args: node: Node to unsubscribe, N)rpop)r r2s r unsubscribezSignal.unsubscribebs d+rc |j}|y|jr |jry|jD]}|jryt |j jD]U\}}|jr|jr |jr|j j|F|D] } || Wy#t$r(}tjd|d|d|Yd}~=d}~wwxYw)zPublish the signal (invoke subscribed callbacks). Args: data: An argument to pass to the callbacks. Nzerror publishing signal to z ignored (callback=z); ) r! is_attached_pruningancestors_with_selfr6r&ritemsr= Exceptionr error)r r-r! ancestor_noder2r:r.rEs rpublishzSignal.publishjs  =   ENN "66 M ++  $D$7$7$=$=$?@ OD)OO(8(8T]]##''-!*H  % 9$?RS[R\\_`e_fgs7C C5 C00C5N)r!rr"strr4r5)r4zrich.repr.Result)r4zDOMNode | None)F)r2rr.zSignalCallbackType[SignalT]r9boolr4r5)r2rr4r5r3) rrrrr#r)propertyr!r;r>rGrrrrrs_p  @  &*&*.&* &*  &*P,rr)r __future__rtypingrrrrrr r weakrefr r rich.reprrichtextualr textual.domrrSignalCallbackTyperDrreprautorrrrrUs#SSS*# )  gY # &'7)S.)AA $)$gWW ggr