/usr/lib/python3/dist-packages/twisted/words/xish/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/words/xish/__pycache__/utility.cpython-310.pyc (12987B)
o
¯b?4 ã @ sX d Z ddlmZ ddlmZ G dd„ dƒZG dd„ dƒZG dd „ d ƒZG d
d „ d ƒZd S )
z+
Event Dispatching and Callback utilities.
é )Úlog)Úxpathc @ s e Zd ZdZdd„ Zdd„ ZdS )Ú_MethodWrapperz3
Internal class for tracking method calls.
c O s || _ || _|| _d S ©N)ÚmethodÚargsÚkwargs)Úselfr r r © r
ú} 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}.
ú//event/c C s" || _ i | _i | _d| _g | _d S )Nr )ÚprefixÚ_eventObserversÚ_xpathObserversÚ_dispatchDepthÚ _updateQueue)r Ú eventprefixr
r
r r ¢ s
zEventDispatcher.__init__c C sX t |tjƒr
| j}||fS | j|d t| jƒ… kr | j}||fS t |¡}| j}||fS r )Ú
isinstancer Ú
XPathQueryr* r( r$ r) Ú internQuery)r ÚeventÚ observersr
r
r Ú_getEventAndObserversª s
ø
ýz%EventDispatcher._getEventAndObserversr c O ó" | j d|||g|¢R i |¤Ž dS )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©Ú _addObserver©r r1 Ú
observerfnÚpriorityr r r
r
r ÚaddOnetimeObserver¹ s "z"EventDispatcher.addOnetimeObserverc O r4 )aþ
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}
FNr5 r7 r
r
r Ú addObserver s "zEventDispatcher.addObserverc
s¢ ˆj dkrˆj ‡ ‡‡‡‡‡‡fdd„¡ d S ˆ ˆ¡\‰}ˆ|vr,tƒ }ˆ|i|ˆ< n|ˆ } ˆ| vr>tƒ }||ˆ ˆ< n| ˆ }|jˆˆgˆ ¢R i ˆ¤Ž d S )Nr c s ˆj ˆˆˆˆgˆ ¢R i ˆ¤ŽS r r5 r
©r r1 r r8 r r9 r r
r ÚÞ s ÿÿÿz.EventDispatcher._addObserver..)r+ r, Úappendr3 r r )
r r r1 r8 r9 r r r2 ÚcblÚpriorityObserversr
r< r r6 Ù s
ÿ z EventDispatcher._addObserverc s ˆj dkrˆj ‡ ‡‡fdd„¡ dS ˆ ˆ ¡\‰ }g }| ¡ D ]!\}}| ¡ D ]\}}ˆ |kr@| ˆ¡ | ¡ r@| ||f¡ q(q |D ] \}}|| |= qDdS )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.
r c s ˆ ˆ ˆ¡S r )ÚremoveObserverr
©r1 r8 r r
r r= ó z0EventDispatcher.removeObserver..N)r+ r, r> r3 r r r% ) r r1 r8 r2 Ú
emptyListsr9 r@ ÚqueryÚ callbacklistr
rB r rA ó s
€ü ÿz EventDispatcher.removeObserverNc sö d}| j d7 _ ˆ dkr| j}‡ fdd„}n| j}dd„ }t| ¡ ƒ}| ¡ | ¡ g }|D ]$}|| ¡ D ]\} }
|| |ƒrS|
|¡ d}|
¡ rS|
|| f¡ q8q0|D ] \}} || | = qW| j d8 _ | j dkry| j D ]} | ƒ qpg | _ |S ) 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}
Fé Nc s | ˆ kS r r
©rE Úobj©r1 r
r r= ( s z*EventDispatcher.dispatch..c S s
| |¡S r )ÚmatchesrH r
r
r r= , s
Tr ) r+ r) r* r ÚkeysÚsortÚreverser r# r% r> r, ) r rI r1 Ú foundTargetr2 ÚmatchÚ
prioritiesrD r9 rE rF Úfr
rJ r Údispatch s8
€û
zEventDispatcher.dispatch)r' )r r ) r r r r r r3 r: r; r6 rA rS r
r
r
r r& y s
(
r& c @ s e Zd ZdZdd„ ZdS )ÚXmlPipeaw
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 s4 t ƒ ˆ _t ƒ ˆ _‡ fdd„ˆ j_‡ fdd„ˆ j_d S )Nc ó ˆ j | ¡S r )ÚsinkrS ©rI r r
r r= k rC z"XmlPipe.__init__..c rU r )ÚsourcerS rW r r
r r= l rC )r& rX rV Úsendr r
r r r h s zXmlPipe.__init__N)r r r r r r
r
r
r rT L s rT N) r Útwisted.pythonr Útwisted.words.xishr r r r& rT r
r
r
r Ú s Y T