כh?4pSrSSKJr SSKJr "SS5r"SS5r"SS 5r"S S 5rg ) z+ Event Dispatching and Callback utilities. )log)xpathc$\rSrSrSrSrSrSrg)_MethodWrapperz+ Internal class for tracking method calls. c(XlX lX0lgN)methodargskwargs)selfr r r s ^C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/words/xish/utility.py__init___MethodWrapper.__init__s   cURU-nURR5nURU5 UR"U0UD6 gr )r r copyupdater )r r r nargsnkwargss r__call___MethodWrapper.__call__s? D ++""$v U&g&r)r r r N)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__rrrrs 'rrc6\rSrSrSrSrSrSrSrSr Sr g ) CallbackList a Container for callbacks. Event queries are linked to lists of callables. When a matching event occurs, these callables are called in sequence. One-time callbacks are removed from the list after the first time the event was triggered. Arguments to callbacks are split spread across two sets. The first set, callback specific, is passed to C{addCallback} and is used for all subsequent event triggers. The second set is passed to C{callback} and is event specific. Positional arguments in the second set come after the positional arguments of the first set. Keyword arguments in the second set override those in the first set. @ivar callbacks: The registered callbacks as mapping from the callable to a tuple of a wrapper for that callable that keeps the callback specific arguments and a boolean that signifies if it is to be called only once. @type callbacks: C{dict} c0Ulgr  callbacksr s rrCallbackList.__init__6s rc`X R;a[U/UQ70UD6U4URU'gg)ai Add callback. The arguments passed are used as callback specific arguments. @param onetime: If C{True}, this callback is called at most once. @type onetime: C{bool} @param method: The callback callable to be added. @param args: Positional arguments to the callable. @type args: C{list} @param kwargs: Keyword arguments to the callable. @type kwargs: C{dict} N)r%r)r onetimer r r s r addCallbackCallbackList.addCallback9s5  '&4V&Md&Mf&Mw%WDNN6 " (rc>XR;aURU gg)z> Remove callback. @param method: The callable to be removed. Nr$)r r s rremoveCallbackCallbackList.removeCallbackKs ^^ #v& $rc[URR55H'unupEU"U0UD6 U(dMURU M) g![a [R "5 N>"a''rr$N) rrrrrrr*r-r6r:rrrrr!r! s!*X$'(4(rr!cR\rSrSrSrS SjrSrS SjrS SjrSr Sr SS jr S r g )EventDispatcherya Event dispatching service. The C{EventDispatcher} allows observers to be registered for certain events that are dispatched. There are two types of events: XPath events and Named events. Every dispatch is triggered by calling L{dispatch} with a data object and, for named events, the name of the event. When an XPath type event is dispatched, the associated object is assumed to be an L{Element} instance, which is matched against all registered XPath queries. For every match, the respective observer will be called with the data object. A named event will simply call each registered observer for that particular event name, with the data object. Unlike XPath type events, the data object is not restricted to L{Element}, but can be anything. When registering observers, the event that is to be observed is specified using an L{xpath.XPathQuery} instance or a string. In the latter case, the string can also contain the string representation of an XPath expression. To distinguish these from named events, each named event should start with a special prefix that is stored in C{self.prefix}. It defaults to C{//event/}. Observers registered using L{addObserver} are persistent: after the observer has been triggered by a dispatch, it remains registered for a possible next dispatch. If instead L{addOnetimeObserver} was used to observe an event, the observer is removed from the list of observers after the first observed event. Observers can also be prioritized, by providing an optional C{priority} parameter to the L{addObserver} and L{addOnetimeObserver} methods. Higher priority observers are then called before lower priority observers. Finally, observers can be unregistered by using L{removeObserver}. cHXl0Ul0UlSUl/Ulg)Nr)prefix_eventObservers_xpathObservers_dispatchDepth _updateQueue)r eventprefixs rrEventDispatcher.__init__s'! !!rc[U[R5(aURnX4$URUS[ UR5:XaUR nX4$[R"U5nURnX4$r ) isinstancer XPathQueryrBr@r9rA internQuery)r event observerss r_getEventAndObservers%EventDispatcher._getEventAndObserverss eU-- . .,,I{{e$6c$++&677 00 ))%0 00 rc4UR"SXU/UQ70UD6 g)z Register a one-time observer for an event. Like L{addObserver}, but is only triggered at most once. See there for a description of the parameters. TN _addObserverr rK observerfnpriorityr r s raddOnetimeObserver"EventDispatcher.addOnetimeObservers  $8MdMfMrc4UR"SXU/UQ70UD6 g)av Register an observer for an event. Each observer will be registered with a certain priority. Higher priority observers get called before lower priority observers. @param event: Name or XPath query for the event to be monitored. @type event: C{str} or L{xpath.XPathQuery}. @param observerfn: Function to be called when the specified event has been triggered. This callable takes one parameter: the data object that triggered the event. When specified, the C{*args} and C{**kwargs} parameters to addObserver are being used as additional parameters to the registered observer callable. @param priority: (Optional) priority of this observer in relation to other observer that match the same event. Defaults to C{0}. @type priority: C{int} FNrPrRs r addObserverEventDispatcher.addObservers * %HNtNvNrc H^^^^^^^TRS:a&TRRUUUUUUU4Sj5 gTRT5umnTU;a[ 5nTU0UT'O"UTn TU ;a[ 5nXTT'OU TnUR "TT/TQ70TD6 g)Nrc6>TR"TTTT/TQ70TD6$r rP)r rKr rSr)rTr sr.EventDispatcher._addObserver..s)))UJ;?CIr)rCrDappendrMr!r*) r r)rKrSrTr r rLcblpriorityObserverss ``````` rrQEventDispatcher._addObservers    "    $ $  55e<y 9 $.C#(#,Ih  )( 3 --"n-0(#E*'. =d=f=rc^^^TRS:a"TRRUUU4Sj5 gTRT5umn/nUR 5H`upVUR 5HGupxTU:XdM UR T5 UR 5(dM5URXW45 MI Mb UH upWX5U M g)a' Remove callable as observer for an event. The observer callable is removed for all priority levels for the specified event. @param event: Event for which the observer callable was registered. @type event: C{str} or L{xpath.XPathQuery} @param observerfn: Observer callable to be unregistered. rc(>TRTT5$r )removeObserver)rKrSr srr\0EventDispatcher.removeObserver..sT-@-@ -SrN)rCrDr^rMr1r-r:) r rKrSrL emptyListsrTr`query callbacklists ``` rrdEventDispatcher.removeObservers    "    $ $%S T 55e<y +4??+< 'H'8'>'>'@#E> // ;#++--"))8*;< (A,= *OH#E* *rNc^SnU=RS- slTS:waURnU4SjnOURnSn[UR 55nUR 5 UR 5 /nUHinXHR5HPupU"X5(dMU RU5 SnU R5(dM>URX45 MR Mk UH upXHU M U=RS-slURS:Xa!URH n U "5 M /Ul U$)a Dispatch an event. When C{event} is L{None}, an XPath type event is triggered, and C{obj} is assumed to be an instance of L{Element}. Otherwise, C{event} holds the name of the named event being triggered. In the latter case, C{obj} can be anything. @param obj: The object to be dispatched. @param event: Optional event name. @type event: C{str} FNc>UT:H$r r)rgobjrKs rr\*EventDispatcher.dispatch..(s u~rc$URU5$r )matches)rgrms rr\rn,s u}}S'9rTr) rCrArBr0keyssortreverser1r6r:r^rD) r rmrK foundTargetrLmatch prioritiesrfrTrgrhfs ` rdispatchEventDispatcher.dispatchs1  q  D=,,I5E,,I9E)..*+  "H'0':'@'@'B#$$ ))#."&K#++--"))8*;< (C# *OH#E* * q    ! #&&' "D r)rCrArDrBr@)z//event/)rr ) rrrrrrrMrUrXrQrdrxrrrrr=r=ys-&P  NO.>4+>7rr=c\rSrSrSrSrSrg)XmlPipeiLa# XML stream pipe. Connects two objects that communicate stanzas through an XML stream like interface. Each of the ends of the pipe (sink and source) can be used to send XML stanzas to the other side, or add observers to process XML stanzas that were sent from the other side. XML pipes are usually used in place of regular XML streams that are transported over TCP. This is the reason for the use of the names source and sink for both ends of the pipe. The source side corresponds with the entity that initiated the TCP connection, whereas the sink corresponds with the entity that accepts that connection. In this object, though, the source and sink are treated equally. Unlike Jabber L{XmlStream}s, the sink and source objects are assumed to represent an eternal connected and initialized XML stream. As such, events corresponding to connection, disconnection, initialization and stream errors are not dispatched or processed. @since: 8.2 @ivar source: Source XML stream. @ivar sink: Sink XML stream. c^[5Tl[5TlU4SjTRlU4SjTRlg)Nc:>TRRU5$r )sinkrxrmr s rr\"XmlPipe.__init__..kstyy'9'9#'>rc:>TRRU5$r )sourcerxrs rr\rlsT[[%9%9#%>r)r=rr~sendr&s`rrXmlPipe.__init__hs.%' #% > > r)r~rN)rrrrrrrrrrr{r{Ls 6?rr{N) rtwisted.pythonrtwisted.words.xishrrr!r=r{rrrrs@  $''"V(V(rPPf ? ?r