U
vie @ 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 )IOLoopSchedulerzA scheduler that schedules work via the Tornado I/O main event loop.
Note, as of Tornado 6, this is just a wrapper around the asyncio loop.
http://tornado.readthedocs.org/en/latest/ioloop.htmlN)loopreturnc s t || _dS )zCreate a new IOLoopScheduler.
Args:
loop: The ioloop to use; typically, you would get this by
tornado import ioloop; ioloop.IOLoop.current()
N)super__init___loop)selfr __class__ ^/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/ioloopscheduler.pyr s
zIOLoopScheduler.__init__)actionstater 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 sj d_d S Nr Z
invoke_actionZ
disposabler r disposedsadr r r r interval5 s z*IOLoopScheduler.schedule..intervalc s d d S )NTr r )r r r dispose; s z)IOLoopScheduler.schedule..dispose)r
r Z add_callbackr r )r r r r" r# r r r schedule$ s zIOLoopScheduler.schedule)duetimer r r c sz |}|dkr j dS 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).
g r Nr c s j d_d S r r r )r r! r r r r r" Y s z3IOLoopScheduler.schedule_relative..intervalz timeout: %sc s j j d S )N)r Zremove_timeoutr )r timerr r r# _ s z2IOLoopScheduler.schedule_relative..dispose) Z
to_secondsr$ r
logdebugr
call_laterr r )r r% r r secondsr" r# r )r r! r r r& r schedule_relativeA s
z!IOLoopScheduler.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_absolutee s
z!IOLoopScheduler.schedule_absoluter c C s | | 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, r time)r r r r r- z s
zIOLoopScheduler.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