&GRM@sdZddlZddlZddlZddlZddlZddlZddlmZm Z m Z Gddde Z Gddde Z Gdd d ZGd d d ejZeZejGd d d eZGddde ZeZdS)a8 Module yoton.events Yoton comes with a simple event system to enable event-driven applications. All channels are capable of running without the event system, but some channels have limitations. See the documentation of the channels for more information. Note that signals only work if events are processed. N)Property getErrorMsg PackageQueuec@s^eZdZdZddgZddZddZdd Zd d Zd d Z dS)CallableObjectak CallableObject(callable) A class to hold a callable. If it is a plain function, its reference is held (because it might be a closure). If it is a method, we keep the function name and a weak reference to the object. In this way, having for instance a signal bound to a method, the object is not prevented from being cleaned up. _ob_funccCst|dstdnt|drTtj|j|_|jj|_nHt|drtj|j |_|j j|_n||_d|_dS)N__call__z&Error: given callback is not callable.__self__im_self) hasattr ValueErrorweakrefrefr r__func____name__rr Zim_func)selfcrG/Applications/pyzo2014a/lib/python3.4/site-packages/iep/yoton/events.py__init__-s zCallableObject.__init__cCs!|jr|jdkSdSdS)z, Get whether the weak ref is dead. NF)r)rrrrisdeadAs zCallableObject.isdeadcCsd|jr:|jr:|j|jko9|j|jkS|jpI|js\|j|jkSdSdS)z- compare this instance with another. FN)rr)rotherrrrcompareJs (zCallableObject.comparecCs |jjS)N)r__str__)rrrrrTszCallableObject.__str__cOs|jrdSy1|jr7t|j|j}n |j}Wntk rYdSYnXy|||SWn)tk rtdttYnXdS)z] call(*args, **kwargs) Call the callable. Exceptions are caught and printed. NzException while handling event:)rrgetattrr Exceptionprintr)rargskwargsfuncrrrcallWs       zCallableObject.callN) r __module__ __qualname____doc__ __slots__rrrrr rrrrr!s    rc@sLeZdZdZddddgZddZdd Zd d Zd S) Eventz Event(callable, *args, **kwargs) An Event instance represents something that is going to be done. It consists of a callable and arguments to call it with. Instances of this class populate the event queue. _callable_args_kwargs_timeoutcOs@t|tr||_nt||_||_||_dS)N) isinstancerr&r'r()rcallablerrrrrrzs   zEvent.__init__cCs|jj|j|jdS)z| dispatch() Call the callable with the arguments and keyword-arguments specified at initialization. N)r&r r'r()rrrrdispatchszEvent.dispatchcCstj|dS)z- This is what theTimerThread calls. N)app post_event)rrrr _on_timeoutszEvent._on_timeoutN)rr!r"r#r$rr,r/rrrrr%ps   r%c@sgeZdZdZddZeddZddZdd d Zd d Z d dZ dS)Signala Signal() The purpose of a signal is to provide an interface to bind/unbind to events and to fire them. One can bind() or unbind() a callable to the signal. When emitted, an event is created for each bound handler. Therefore, the event loop must run for signals to work. Some signals call the handlers using additional arguments to specify specific information. cCs g|_dS)N) _handlers)rrrrrszSignal.__init__cCs|jS)z. The type (__class__) of this event. ) __class__)rrrrtypesz Signal.typecCs[t|}x8|jD]-}|j|rtd||fdSqW|jj|dS)a bind(func) Add an eventhandler to this event. The callback/handler (func) must be a callable. It is called with one argument: the event instance, which can contain additional information about the event. z*Warning: handler %s already present for %sN)rr1rrappend)rrZcnewrrrrbinds z Signal.bindNcCs|dkr"g|jdds z!Signal.unbind..)r1rrrremove)rrZcrefrrrrunbinds   z Signal.unbindcOszg}xL|jD]A}|jr2|j|qt|||}tj|qWx|D]}|jj|q\WdS)a  emit(*args, **kwargs) Emit the signal, calling all bound callbacks with *args and **kwargs. An event is queues for each callback registered to this signal. Therefore it is safe to call this method from another thread. N)r1rr4r%r-r.r8)rrrtoremovereventrrremits   z Signal.emitcOskg}x=|jD]2}|jr2|j|q|j||qWx|D]}|jj|qMWdS)z emit_now(*args, **kwargs) Emit the signal *now*. All handlers are called from the calling thread. Beware, this should only be done from the same thread that runs the event loop. N)r1rr4r r8)rrrr:rrrremit_nows   zSignal.emit_now) rr!r"r#rpropertyr3r5r9r<r=rrrrr0s    r0c@smeZdZdZddZdddZddZd d Zd d Zd dZ ddZ dS)TheTimerThreada TheTimerThread is a singleton thread that is used by all timers and delayed events to wait for a while (in a separate thread) and then post an event to the event-queue. By sharing a single thread timers stay lightweight and there is no time spend on initializing or tearing down threads. The downside is that when there are a lot of timers running at the same time, adding a timer may become a bit inefficient because the registered objects must be sorted each time an object is added. cCsTtjj||jdd|_g|_d|_tjtj|_ dS)NTF) threadingThreadr setDaemon_exit_timers_somethingChanged ConditionLock _condition)rrrrrs     zTheTimerThread.__init__g?c CsId|_|jjz|jjWd|jjX|j|dS)NT)rCrHacquirenotifyreleasejoin)rtimeoutrrrstops   zTheTimerThread.stopc Cst|dot|ds-tdn|jjzF||jkrr|jj||jd|_n|jjWd|jj XdS)z add(timer) Add item to the list of objects to track. The object should have a _timeout attribute, representing the time.time() at which it runs out, and an _on_timeout() method to call when it does. r)r/z)Cannot add this object to theTimerThread.TN) r r rHrIrDr4_sortrErJrK)rtimerrrradds   zTheTimerThread.addcCs(t|jddddd|_dS)NkeycSs|jS)N)r))xrrr/sz&TheTimerThread._sort..reverseT)sortedrD)rrrrrO-s zTheTimerThread._sortc Cs^|jjz<||jkr2|jj|nd|_|jjWd|jjXdS)z(Stop the timer if it hasn't finished yetTN)rHrIrDr8rErJrK)rrPrrrdiscard1s  zTheTimerThread.discardc Cs0|jjz|jWd|jjXdS)N)rHrI _mainlooprK)rrrrrun<s zTheTimerThread.runcCsx|jsd|_|jr`|jd}|jtj}|dkrs|jj|qsnd}|jj|jrPn|dk r|j r|jr|jq|jj qqWdS)NFr) rCrErDr)timerHwaitr/rOpop)rrPrMrrrrXCs         zTheTimerThread._mainloopN) rr!r"r#rrNrQrOrWrYrXrrrrr?s     r?c@seZdZdZddddZeddZedd Zed d Z d d d dZ ddZ ddZ d S)Timera] Timer(interval=1.0, oneshot=True) Timer class. You can bind callbacks to the timer. The timer is fired when it runs out of time. Parameters ---------- interval : number The interval of the timer in seconds. oneshot : bool Whether the timer should do a single shot, or run continuously. g?TcCs,tj|||_||_d|_dS)Nr)r0rintervaloneshotr))rr`rarrrrts   zTimer.__init__cCsdd}dd}tS)z2 Set/get the timer's interval in seconds. cSs|jS)N) _interval)rrrrfgetszTimer.interval..fgetcSsRt|ttfs$tdn|dkr?tdnt||_dS)Nz$interval must be a float or integer.rzinterval must be larger than 0.)r*intfloatr rb)rvaluerrrfsets  zTimer.interval..fset)locals)rcrgrrrr`~s  zTimer.intervalcCsdd}dd}tS)zW Set/get whether this is a oneshot timer. If not is runs continuously. cSs|jS)N)_oneshot)rrrrrcszTimer.oneshot..fgetcSst||_dS)N)boolri)rrfrrrrgszTimer.oneshot..fset)rh)rcrgrrrras  z Timer.oneshotcCs |jdkS)z, Get whether the timer is running. r)r))rrrrrunningsz Timer.runningNcCsW|dk r||_n|dk r0||_ntj|j|_tj|dS)z start(interval=None, oneshot=None) Start the timer. If interval or oneshot are not given, their current values are used. N)r`rar\r)theTimerThreadrQ)rr`rarrrstarts     z Timer.startcCstj|d|_dS)zH stop() Stop the timer from running. rN)rlrWr))rrrrrNs z Timer.stopcCs>|j|jr d|_dStj|j|_dSdS)zY Method to call when the timer finishes. Called from event-loop-thread. rFTN)r<rar)r\r`)rrrrr/s    zTimer._on_timeout) rr!r"r#rrr`rar>rkrmrNr/rrrrr_es    r_c@seZdZdZeddZdZdZdZdZ dddZ d d Z d d Z d dZ dddZddZddZddZdS)YotonApplicationa YotonApplication Represents the yoton application and contains functions for the event system. Multiple instances can be created, they will all operate on the same event queue and share attributes (because these are on the class, not on the instance). One instance of this class is always accesible via yoton.app. For convenience, several of its methods are also accessible directly from the yoton module namespace. i'newFNgcOs^t|||}|dkr1|j||n)|dkrM|j|n |j|dS)aw call_later(func, timeout=0.0, *args, **kwargs) Call the given function after the specified timeout. Parameters ---------- func : callable The function to call. timeout : number The time to wait in seconds. If zero, the event is put on the event queue. If negative, the event will be put at the front of the event queue, so that it's processed asap. args : arguments The arguments to call func with. kwargs: keyword arguments. The keyword arguments to call func with. rN)r%post_event_laterpost_event_asapr.)rrrMrrr;rrr call_laters   zYotonApplication.call_latercCs9tjj|tjdk r5dt_tjndS)zX post_event(events) Post an event to the event queue. N)rn _event_queuepush_embedding_callback2_embedding_callback1)rr;rrrr.s zYotonApplication.post_eventcCs9tjj|tjdk r5dt_tjndS)z post_event_asap(event) Post an event to the event queue. Handle as soon as possible; putting it in front of the queue. N)rnrsinsertrurv)rr;rrrrqs z YotonApplication.post_event_asapcCs$tj||_tj|dS)z~ post_event_later(event, delay) Post an event to the event queue, but with a certain delay. N)r\r)rlrQ)rr;Zdelayrrrrp)sz!YotonApplication.post_event_laterc CsTtjt_y,x%tjj|}|jd}qWntjk rOYnXdS)a[ process_events(block=False) Process all yoton events currently in the queue. This function should be called periodically in order to keep the yoton event system running. block can be False (no blocking), True (block), or a float blocking for maximally 'block' seconds. FN)rnrvrursr^r,rEmpty)rblockr;rrrprocess_events4s   zYotonApplication.process_eventsc CsQtjr dSdt_dt_z!xtjs>|jdq%WWddt_XdS)z start_event_loop() Enter an event loop that keeps calling yoton.process_events(). The event loop can be stopped using stop_event_loop(). NFTg@)rn_in_event_loop_stop_event_looprz)rrrrstart_event_loopLs    z!YotonApplication.start_event_loopcCs8tjs4dt_dd}|jt|ndS)z\ stop_event_loop() Stops the event loop if it is running. TcSsdS)Nrrrrrdummyosz/YotonApplication.stop_event_loop..dummyN)rnr|r.r%)rr~rrrstop_event_loopes   z YotonApplication.stop_event_loopcCs|t_|t_dS)a embed_event_loop(callback) Embed the yoton event loop in another event loop. The given callback is called whenever a new yoton event is created. The callback should create an event in the other event-loop, which should lead to a call to the process_events() method. The given callback should be thread safe. Use None as an argument to disable the embedding. N)rnrvru)rZcallbackrrrembed_event_loopss z!YotonApplication.embed_event_loop)rr!r"r#rrsr|r{rvrurrr.rqrprzr}rrrrrrrns     rn)r#ossysr\r@r yoton yoton.miscrrrobjectrr%r0rAr?rlrmr_rnr-rrrrs$   O oa  l