U
vi @ s d dl Z d dlZd dlmZ d dlmZmZ d dlmZmZ d dlm Z m
Z
m Z ddl m
Z
edZed ZG d
d d e
ZdS ) N)datetime)OptionalTypeVar)abctyping)CompositeDisposable
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStateZRxc s e Zd ZdZejdd fdd Zdeje e
e e j dddZ
dejeje e
e e j d d
d Zdejeje e
e e j d d d
ZeedddZ ZS )AsyncIOSchedulerzA scheduler that schedules work via the asyncio mainloop. This class
does not use the asyncio threadsafe methods, if you need those please use
the AsyncIOThreadSafeScheduler class.N)loopreturnc s t || _dS )zCreate a new AsyncIOScheduler.
Args:
loop: Instance of asyncio event loop to use; typically, you would
get this by asyncio.get_event_loop()
N)super__init___loop)selfr __class__ _/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/asyncioscheduler.pyr s
zAsyncIOScheduler.__init__)actionstater c sJ t dd 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).
Nr c s j d_d S Nr Z
invoke_actionZ
disposabler r sadr r r r interval1 s z+AsyncIOScheduler.schedule..intervalc s d S Ncancelr handler r dispose6 s z*AsyncIOScheduler.schedule..dispose)r r call_soonr r )r r r r r& r r r% r r r r schedule" s
zAsyncIOScheduler.schedule)duetimer r r c sj |}|dkr S t dd fdd }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 j d_d S r r r r r r r R s z4AsyncIOScheduler.schedule_relative..intervalc s d S r! r" r r$ r r r& W s z3AsyncIOScheduler.schedule_relative..dispose)Z
to_secondsr) r r
call_laterr r )r r* r r secondsr r& r r( r schedule_relative; s
z"AsyncIOScheduler.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_absolute\ s
z"AsyncIOScheduler.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/ q s
zAsyncIOScheduler.now)N)N)N)__name__
__module__ __qualname____doc__asyncioAbstractEventLoopr r ZScheduledActionr r r ZDisposableBaser) Z RelativeTimer- Z AbsoluteTimer0 propertyr r/
__classcell__r r r r r
s0 % r
)r6 loggingr r r r Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r getLoggerlogr
r r r r s