U
vi-
@ s~ d dl Z d dlmZ d dlmZmZmZ d dlmZmZ d dlm Z m
Z
m Z ddl m
Z
edZe d ZG d
d d e
ZdS ) N)datetime)AnyOptionalTypeVar)abctyping)CompositeDisposable
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStateZRxc s e Zd ZdZedd fdd Zdeje e e e
j dddZ dej
eje e e e
j d d
d Zdejeje e e e
j d d d
ZeedddZ ZS )TwistedSchedulerzAA scheduler that schedules work via the Twisted reactor mainloop.N)reactorreturnc s t || _dS )zCreate a new TwistedScheduler.
Args:
reactor: The reactor to use; typically, you would get this
by from twisted.internet import reactor
N)super__init___reactor)selfr __class__ _/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/twistedscheduler.pyr s
zTwistedScheduler.__init__)actionstater c 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).
r )schedule_relative)r r r r r r schedule s zTwistedScheduler.schedule)duetimer r r c sh t d|}t dd fdd }td| j||ddfdd }tt|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 Nr c s _ d S N)Z
disposabler )r sadr r r r intervalF s z4TwistedScheduler.schedule_relative..intervalz timeout: %sc s j s d S r! )calledcancelr )timerr r disposeL s z3TwistedScheduler.schedule_relative..dispose) maxZ
to_secondsr
logdebugr Z callLaterr r )r r r r secondsr# r' r )r r" r r r& r r 0 s z"TwistedScheduler.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_datetimer now)r r r r r r r schedule_absoluteR s
z"TwistedScheduler.schedule_absoluter c C s | t| j S )zRepresents a notion of time for this scheduler. Tasks being
scheduled on a scheduler will adhere to the time denoted by this
property.
Returns:
The scheduler's current time, as a datetime instance.
)r, floatr r+ )r r r r r- g s
zTwistedScheduler.now)N)N)N)__name__
__module__ __qualname____doc__r r r ZScheduledActionr
r r ZDisposableBaser Z RelativeTimer Z AbsoluteTimer. propertyr r-
__classcell__r r r r r s0 & r )loggingr r r r r Z reactivexr Zreactivex.disposabler r r
Zperiodicschedulerr r
getLoggerr) r r r r r s