U
vi @ sz d dl Z d dlmZmZmZmZmZ d dlmZmZ d dl m
Z
m Z m Z ddl
mZ edZe dZG d d
d
eZdS ) N)AnyOptionalSetTypeVarcast)abctyping)CompositeDisposable
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStateZRxc s e Zd ZdZedd fdd ZddddZdejej e
e e
e e
jd
d d Zdeje
e e
e
jd
ddZdejeje
e e
e
jdddZdejeje
e e
e
jdddZd ejeje
e e
e
jdddZ ZS ) WxSchedulerz&A scheduler for a wxPython event loop.N)wxreturnc s: t || _| jj}G dd d|}|| _t | _dS )zCreate a new WxScheduler.
Args:
wx: The wx module to use; typically, you would get this by
import wx
c s4 e Zd Zejdd fdd ZddddZ ZS )z#WxScheduler.__init__..TimerN)callbackr c s t || _d S N)super__init__r )selfr __class__ Y/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/wxscheduler.pyr " s
z,WxScheduler.__init__..Timer.__init__r c S s | d S r )r )r r r r Notify& s z*WxScheduler.__init__..Timer.Notify)__name__
__module__ __qualname__r Actionr r
__classcell__r r r r Timer! s r" N)r r _wxr" _timer_classset_timers)r r Z timer_classr" r r r r s
zWxScheduler.__init__r c C s | j D ] }| qdS )zCancel all scheduled actions.
Should be called when destroying wx controls to prevent
accessing dead wx objects in actions that might be pending.
N)r& Stopr timerr r r
cancel_all, s
zWxScheduler.cancel_allF)timeactionstateperiodicr c s t d d fdd }tdt|d }td| |j rnj | d njj
j | d j d dfdd }t
t|S )
Nr c s6 rt tjt nt tjt _d S r )r r ScheduledPeriodicActionr ScheduledAction
disposabler )r, r. sad schedulerr- r r interval@ s z/WxScheduler._wxtimer_schedule..interval g @@ztimeout wx: %s)ZoneShotc s j d S r )r' r& remover r( r r disposeU s z.WxScheduler._wxtimer_schedule..dispose)r maxintZ
to_secondslogdebugr$ r# Z IsMainThreadZStart CallAfterr& addr r
)r r+ r, r- r. r4 msecsr7 r )r, r. r2 r3 r r- r) r _wxtimer_schedule5 s
z WxScheduler._wxtimer_schedule)r, r- r c sP t ddd fdd }j| ddfdd }tt|S )a! Schedules an action to be executed.
Args:
action: Action to be executed.
state: [Optional] state to be given to the action function.
Returns:
The disposable object used to cancel the scheduled action
(best effort).
FNr c s s _ d S r )r1 r r, is_disposedr2 r r- r r
invoke_actionk s z+WxScheduler.schedule..invoke_actionc s d d S )NTr r )rA r r r7 q s z%WxScheduler.schedule..dispose)r r# r< r r
)r r, r- rB r7 r r@ r schedule[ s
zWxScheduler.schedule)duetimer, r- r c C s | j |||dS )au Schedules an action to be executed after duetime.
Args:
duetime: Relative time after which to execute the action.
action: Action to be executed.
state: [Optional] state to be given to the action function.
Returns:
The disposable object used to cancel the scheduled action
(best effort).
r- r? r rD r, r- r r r schedule_relativew s z WxScheduler.schedule_relativec C s | |}| j|| j ||dS )ao Schedules an action to be executed at duetime.
Args:
duetime: Absolute time at which to execute the action.
action: Action to be executed.
state: [Optional] state to be given to the action function.
Returns:
The disposable object used to cancel the scheduled action
(best effort).
rE ) to_datetimer? nowrG r r r schedule_absolute s
z WxScheduler.schedule_absolute)periodr, r- r c C s | j |||ddS )a Schedules a periodic piece of work to be executed in the loop.
Args:
period: Period in seconds for running the work repeatedly.
action: Action to be executed.
state: [Optional] state to be given to the action function.
Returns:
The disposable object used to cancel the scheduled action
(best effort).
T)r- r. rF )r rL r, r- r r r schedule_periodic s z WxScheduler.schedule_periodic)NF)N)N)N)N)r r r __doc__r r r* r ZAbsoluteOrRelativeTimeZ ScheduledSingleOrPeriodicActionr r boolr ZDisposableBaser? r0 rC Z RelativeTimerH Z AbsoluteTimerK r/ rM r! r r r r r sN
' r )loggingr r r r r r Z reactivexr Zreactivex.disposabler r
r Zperiodicschedulerr
r getLoggerr: r r r r r s