ó N`¾Tc@sédZddlmZddlmZddlmZmZmZm Z m Z m Z m Z e dƒZ de _dZdefd „ƒYZed ƒZd efd „ƒYZd efd„ƒYZdefd„ƒYZeƒjZdS(s+Signals and events. A small implementation of signals, inspired by a snippet of Django signal API client code seen in a blog post. Signals are first-class objects and each manages its own receivers and message emission. The :func:`signal` function provides singleton behavior for named signals. iÿÿÿÿ(twarn(tWeakValueDictionary(t WeakTypestcontextmanagert defaultdictthashable_identityt lazy_propertyt referencetsymboltANYsToken for "any sender".itSignalcBsÂeZdZeZed„ƒZed„ƒZdd„Zee d„Z e d„Z e ed„ƒZed„Zd„Zd „Zd „Zed „Zd „Zd „Zd„Zd„ZRS(sA notification emitter.cCs tddƒS(sßEmitted after each :meth:`connect`. The signal sender is the signal instance, and the :meth:`connect` arguments are passed through: *receiver*, *sender*, and *weak*. .. versionadded:: 1.2 tdocs"Emitted after a receiver connects.(R (tself((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pytreceiver_connected%s cCs tddƒS(s Emitted after :meth:`disconnect`. The sender is the signal instance, and the :meth:`disconnect` arguments are passed through: *receiver* and *sender*. Note, this signal is emitted **only** when :meth:`disconnect` is called explicitly. The disconnect signal can not be emitted by an automatic disconnect (due to a weakly referenced receiver or sender going out of scope), as the receiver and/or sender instances are no longer available for use at the time this signal would be emitted. An alternative approach is available by subscribing to :attr:`receiver_connected` and setting up a custom weakref cleanup callback on weak receivers and senders. .. versionadded:: 1.2 R s%Emitted after a receiver disconnects.(R (R ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pytreceiver_disconnected1scCsF|r||_ni|_ttƒ|_ttƒ|_i|_dS(st :param doc: optional. If provided, will be assigned to the signal's __doc__ attribute. N(t__doc__t receiversRtsett _by_receivert _by_sendert _weak_senders(R R ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt__init__Is   c Cs¹t|ƒ}|r0t||jƒ}||_n|}|tkrKt}n t|ƒ}|jj||ƒ|j|j |ƒ|j |j |ƒ~|tk rü||j krüyt||j ƒ}||_ Wntk râqüX|j j||ƒ~nd|jkr]|jjr]y&|jj|d|d|d|ƒWq]|j||ƒ‚q]Xntjrµ|tk rµy#tj|d|d|d|ƒWqµ|j||ƒ‚qµXn|S(saConnect *receiver* to signal events sent by *sender*. :param receiver: A callable. Will be invoked by :meth:`send` with `sender=` as a single positional argument and any \*\*kwargs that were provided to a call to :meth:`send`. :param sender: Any object or :obj:`ANY`, defaults to ``ANY``. Restricts notifications delivered to *receiver* to only those :meth:`send` emissions sent by *sender*. If ``ANY``, the receiver will always be notified. A *receiver* may be connected to multiple *sender* values on the same Signal through multiple calls to :meth:`connect`. :param weak: If true, the Signal will hold a weakref to *receiver* and automatically disconnect when *receiver* goes out of scope or is garbage collected. Defaults to True. R treceivertsendertweakt receiver_argt sender_argtweak_arg(RRt_cleanup_receivert receiver_idR tANY_IDRt setdefaultRtaddRRt_cleanup_sendert sender_idt TypeErrort__dict__R tsendt disconnect(R RRRRt receiver_refR"t sender_ref((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pytconnect\sP             cs‡‡‡fd†}|S(sKConnect the decorated function as a receiver for *sender*. :param sender: Any object or :obj:`ANY`. The decorated function will only receive :meth:`send` emissions sent by *sender*. If ``ANY``, the receiver will always be notified. A function may be decorated multiple times with differing *sender* values. :param weak: If true, the Signal will hold a weakref to the decorated function and automatically disconnect when *receiver* goes out of scope or is garbage collected. Unlike :meth:`connect`, this defaults to False. The decorated function will be invoked by :meth:`send` with `sender=` as a single positional argument and any \*\*kwargs that were provided to the call to :meth:`send`. .. versionadded:: 1.1 csˆj|ˆˆƒ|S(N(R)(tfn(R RR(sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt decoratorµs((R RRR+((R RRsR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt connect_via sccsM|j|d|dtƒy dVWn|j|ƒ‚nX|j|ƒdS(sExecute a block with the signal temporarily connected to *receiver*. :param receiver: a receiver callable :param sender: optional, a sender to filter on This is a context manager for use in the ``with`` statement. It can be useful in unit tests. *receiver* is connected to the signal for the duration of the ``with`` block, and will be disconnected automatically when exiting the block: .. testsetup:: from __future__ import with_statement from blinker import Signal on_ready = Signal() receiver = lambda sender: None .. testcode:: with on_ready.connected_to(receiver): # do stuff on_ready.send(123) .. versionadded:: 1.1 RRN(R)tFalsetNoneR&(R RR((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt connected_toºs  cCstdtƒ|j||ƒS(s_An alias for :meth:`connected_to`. :param receiver: a receiver callable :param sender: optional, a sender to filter on .. versionadded:: 0.9 .. versionchanged:: 1.1 Renamed to :meth:`connected_to`. ``temporarily_connected_to`` was deprecated in 1.2 and removed in a subsequent version. sAtemporarily_connected_to is deprecated; use connected_to instead.(RtDeprecationWarningR/(R RR((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyttemporarily_connected_toßs cOst|ƒdkrd}n5t|ƒdkrFtdt|ƒƒ‚n |d}|js]gSg|j|ƒD]}||||f^qmSdS(s˜Emit this signal on behalf of *sender*, passing on \*\*kwargs. Returns a list of 2-tuples, pairing receivers with their return value. The ordering of receiver notification is undefined. :param \*sender: Any object or ``None``. If omitted, synonymous with ``None``. Only accepts one positional argument. :param \*\*kwargs: Data to be sent to receivers. iis5send() accepts only one positional argument, %s givenN(tlenR.R#Rt receivers_for(R RtkwargsR((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR%ñs   cCsA|js tS|jtrtS|tkr.tSt|ƒ|jkS(sôTrue if there is probably a receiver for *sender*. Performs an optimistic check only. Does not guarantee that all weakly referenced receivers are still alive. See :meth:`receivers_for` for a stronger search. (RR-RRtTrueR R(R R((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pythas_receivers_for s   ccsÖ|jrÒt|ƒ}||jkr?|jt|j|B}n|jtjƒ}x}|D]r}|jj|ƒ}|dkrƒqYnt|tƒrÆ|ƒ}|dkr½|j |tƒqYn|}n|VqYWndS(s2Iterate all live receivers listening for *sender*.N( RRRRtcopytgetR.t isinstanceRt _disconnect(R RR"tidsRRtstrong((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR3s"        cCs{|tkrt}n t|ƒ}t|ƒ}|j||ƒd|jkrw|jjrw|jj|d|d|ƒndS(sDisconnect *receiver* from this signal's events. :param receiver: a previously :meth:`connected` callable :param sender: a specific sender to disconnect from, or :obj:`ANY` to disconnect from all senders. Defaults to ``ANY``. RRRN(R RRR:R$RRR%(R RRR"R((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR&3s     cCsy|tkra|jj|tƒrKx'|jjƒD]}|j|ƒq1Wn|jj|dƒn|j|j|ƒdS(N( RRtpopR-RtvaluestdiscardRR.(R RR"tbucket((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR:Is  cCs|j|jtƒdS(s'Disconnect a receiver from all senders.N(R:RR(R R'((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRRscCsf|j}|tkst‚|jj|dƒx1|jj|dƒD]}|j|j|ƒqDWdS(s'Disconnect all receivers from a sender.N(( R"RtAssertionErrorRR=R.RRR?(R R(R"R((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR!Vs  cCs8|jjƒ|jjƒ|jjƒ|jjƒdS(s4Throw away all signal state. Useful for unit tests.N(RtclearRRR(R ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt _clear_state^s   N(t__name__t __module__RR RR RR.RR5R)R-R,RR/R1R%R6R3R&R:RR!RC(((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR s$  D $       s Sent by a :class:`Signal` after a receiver connects. :argument: the Signal that was connected to :keyword receiver_arg: the connected receiver :keyword sender_arg: the sender to connect to :keyword weak_arg: true if the connection to receiver_arg is a weak reference .. deprecated:: 1.2 As of 1.2, individual signals have their own private :attr:`~Signal.receiver_connected` and :attr:`~Signal.receiver_disconnected` signals with a slightly simplified call signature. This global signal is planned to be removed in 1.6. t NamedSignalcBs#eZdZdd„Zd„ZRS(s%A named generic notification emitter.cCstj||ƒ||_dS(N(R Rtname(R RGR ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyR{scCs$tj|ƒ}d|d |jfS(Ns%s; %r>iÿÿÿÿ(R t__repr__RG(R tbase((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRHsN(RDRERR.RRH(((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRFxs t NamespacecBseZdZdd„ZRS(s%A mapping of signal names to signals.cCs:y ||SWn'tk r5|j|t||ƒƒSXdS(s—Return the :class:`NamedSignal` *name*, creating it if required. Repeated calls to this function will return the same signal object. N(tKeyErrorRRF(R RGR ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pytsignal‰s  N(RDRERR.RL(((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRJ†st WeakNamespacecBseZdZdd„ZRS(sA weak mapping of signal names to signals. Automatically cleans up unused Signals when the last reference goes out of scope. This namespace implementation exists for a measure of legacy compatibility with Blinker <= 1.2, and may be dropped in the future. cCs:y ||SWn'tk r5|j|t||ƒƒSXdS(s—Return the :class:`NamedSignal` *name*, creating it if required. Repeated calls to this function will return the same signal object. N(RKRRF(R RGR ((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRLžs  N(RDRERR.RL(((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyRM•sN(RtwarningsRtweakrefRtblinker._utilitiesRRRRRRRR RtobjectR R RFtdictRJRMRL(((sR/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/blinker/base.pyt s4  ÿI