U
vit @ 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 )GEventSchedulerz[A scheduler that schedules work via the GEvent event loop.
http://www.gevent.org/
N)geventreturnc s t || _dS )zCreate a new GEventScheduler.
Args:
gevent: The gevent module to use; typically ,you would get this by
import gevent
N)super__init___gevent)selfr __class__ ^/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/geventscheduler.pyr s
zGEventScheduler.__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 interval3 s z*GEventScheduler.schedule..intervalc s j dd d S NF)blockkillr timerr r dispose8 s z)GEventScheduler.schedule..dispose)r
r spawnr r )r r r r! r( r r r r r r' r schedule# s
zGEventScheduler.schedule)duetimer r r c sx |}|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! U s z3GEventScheduler.schedule_relative..intervalz timeout: %sc s j dd d S r" r$ r r& r r r( [ s z2GEventScheduler.schedule_relative..dispose) Z
to_secondsr+ r
logdebugr Z spawn_laterr r )r r, r r secondsr! r( r r* r schedule_relative= s
z!GEventScheduler.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_datetimer0 now)r r, r r r r r schedule_absolute` s
z!GEventScheduler.schedule_absoluter c C s | | j 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.
)r1 r Zget_hubloopr2 )r r r r r2 u s
zGEventScheduler.now)N)N)N)__name__
__module__ __qualname____doc__r r r ZScheduledActionr
r r ZDisposableBaser+ Z RelativeTimer0 Z AbsoluteTimer3 propertyr r2
__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