U
vi| @ s d dl Z d dlmZ d dlmZmZmZmZ d dlm Z mZ d dl
m Z m Z m
Z
ddlmZ edZe eZG d d
d
eZdS ) N) timedelta)AnyOptionalSetTypeVar)abctyping)CompositeDisposable
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStatec s e Zd ZdZed fdd Zdeje e e e
j dddZ dej
eje e e e
j d d
d Zdejeje e e e
j d d d
Zdej
eje e e e
j dddZ ZS ) QtSchedulerz+A scheduler for a PyQt5/PySide2 event loop.)qtcorec s t || _t | _dS )zCreate a new QtScheduler.
Args:
qtcore: The QtCore instance to use; typically you would get this by
either import PyQt5.QtCore or import PySide2.QtCore
N)super__init___qtcoreset_periodic_timers)selfr __class__ Y/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/qtscheduler.pyr s
zQtScheduler.__init__N)actionstatereturnc C s | j d||dS )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).
g r )schedule_relative)r r r r r r schedule! s
zQtScheduler.schedule)duetimer r r c sx t dt|d }t ddd fdd }td| jj|| ddfd d
}t t
|S ) 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 @@FNr c s s _ d S N)Z
disposabler r is_disposedsadr r r r
invoke_actionE s z4QtScheduler.schedule_relative..invoke_actionzrelative timeout: %smsc s d d S )NTr r )r& r r disposeN s z.QtScheduler.schedule_relative..dispose) maxint
to_secondsr logdebugr QTimerZ
singleShotr r
)r r! r r msecsr( r) r r% r r 0 s z QtScheduler.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).
r ) to_datetimenowr )r r! r r deltar r r schedule_absoluteT s z QtScheduler.schedule_absolute)periodr r r c s t dt|d }t }dd fdd }td| j | j
| | j
ddfdd }t|t|S )
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).
r r" Nr# c s d S r$ r r )r r r r interval} s z/QtScheduler.schedule_periodic..intervalzperiodic timeout: %smsc s j d S r$ )stopr removeZ deleteLaterr )r timerr r r) s z.QtScheduler.schedule_periodic..dispose)r* r+ r, r r- r. r r/ Z
setSingleShottimeoutconnectZ setIntervalr addstartr r
)r r5 r r r0 r' r6 r) r )r r r r9 r schedule_periodici s
z QtScheduler.schedule_periodic)N)N)N)N)__name__
__module__ __qualname____doc__r r r ZScheduledActionr r r ZDisposableBaser Z RelativeTimer Z AbsoluteTimer4 ZScheduledPeriodicActionr>
__classcell__r r r r r s: ( r )loggingdatetimer r r r r r Z reactivexr Zreactivex.disposabler r
r Zperiodicschedulerr
r getLoggerr? r- r r r r r s