elddlZddlmZddlmZddlmZddlmZdgZGddejZ y) N) perf_counter) SignalBlock)QtCore)ThreadsafeTimer SignalProxycfeZdZdZej eZd dddZdZ dZ dZ d Z d Z d Zy) raPObject which collects rapid-fire signals and condenses them into a single signal or a rate-limited stream of signals. Used, for example, to prevent a SpinBox from generating multiple signals when the mouse wheel is rolled over it. Emits sigDelayed after input signals have stopped for a certain period of time. NT) threadSafectjj|||_||_d|_|rt ntj}||_|jjj|jd|_ ||_ |jj|j|=d|_|j j|t#j$||_yd|_d|_y)aInitialization arguments: signal - a bound Signal or pyqtSignal instance delay - Time (in seconds) to wait for signals to stop before emitting (default 0.3s) slot - Optional function to connect sigDelayed to. rateLimit - (signals/sec) if greater than 0, this allows signals to stream out at a steady rate while they are being received. threadSafe - Specify if thread-safety is required. For backwards compatibility, it defaults to True. NFT)rQObject__init__delay rateLimitargsrQTimertimertimeoutconnectflush lastFlushTimesignalsignalReceived blockSignal sigDelayedweakrefrefslot)selfrrrrr Timers 7/usr/lib/python3/dist-packages/pyqtgraph/SignalProxy.pyr zSignalProxy.__init__s % " #-6==W  ""4::.!  D//0  $D  OO # #D ) D)DI#D DIc||_y)N)r)rrs r setDelayzSignalProxy.setDelay4s  r!c |jry||_|jdk(rO|jj |jj t |jdzdzyt}|jd}n+|j}td|d|jz z|z }|jj |jj t t||jdzdzy)zTReceived signal. Cancel previous timer and store args to be forwarded later.Nrirg?) rrrrstopstartintrrrmaxmin)rrnowleakTime lastFlushs r rzSignalProxy.signalReceived7s     >>Q  JJOO  JJ  Sd!23a7 8.C!!) .. q9dnn0D#E"LM JJOO  JJ  SXtzz!:T!ABQF Gr!c|j |jry|jdc}|_|jjt |_|j j|y)z,If there is a signal queued up, send it now.NFT)rrrr%rrremit)rrs r rzSignalProxy.flushKsU 99  0 0))Tdi )^ T"r!cd|_ |jj|j |j }||j j|d|_y#Y:xYw#YxYw#d|_wxYw)NT)rr disconnectrrrrrs r r0zSignalProxy.disconnectUss  KK " "4#6#6 7 99;D**40DI     DIs"%A$-A+$A(+A/-A22 A;c|jJdtj||_|jj |d|_y)z-Connect the `SignalProxy` to an external slotNzSlot was already connected!F)rrrrrrr1s r connectSlotzSignalProxy.connectSlotdsByy ?"?? KK%  % r!cBt|j|jS)z\Return a SignalBlocker that temporarily blocks input signals to this proxy. )rrr)rs r blockzSignalProxy.blockks4;;(;(;<rAs-", /d=&..d=r!