U
vi @ sx d dl m Z d dlmZmZmZmZ d dlmZmZ d dlm Z d dl
m Z m Z ddl
mZ edZG d d
d
eZd S ) )datetime)CallableOptionalTypeVarcast)abctyping)
SchedulerBase)
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStatec s e Zd Zejeegef dd fdd Ze e
dddZ de j
e ee ejdd d
Zd e je j
e ee ejd d d
Zd e je j
e ee ejd ddZd e je je ee ejdddZejd dddZe j
e e j
e dddZed dddZ ZS ) CatchSchedulerN) schedulerhandlerreturnc s& t || _|| _d| _d| _dS )a Wraps a scheduler, passed as constructor argument, adding exception
handling for scheduled actions. The handler should return True to
indicate it handled the exception successfully. Falsy return values will
be taken to indicate that the exception should be escalated (raised by
this scheduler).
Args:
scheduler: The scheduler to be wrapped.
handler: Callable to handle exceptions raised by wrapped scheduler.
N)super__init__
_scheduler_handler_recursive_original_recursive_wrapper)selfr r __class__ S/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/catchscheduler.pyr s
zCatchScheduler.__init__)r c C s | j jS )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 now)r r r r r " s
zCatchScheduler.now)actionstater c C s | |}| jj||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 )_wrapr schedule)r r r r r r r# . s
zCatchScheduler.schedule)duetimer r r c C s | |}| jj|||dS )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! )r" r schedule_relativer r$ r r r r r r% ? s
z CatchScheduler.schedule_relativec C s | |}| jj|||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! )r" r schedule_absoluter& r r r r' T s
z CatchScheduler.schedule_absolute)periodr r r c sh t jd}t|stt ddtt tt d fdd
}ttj}|j |||d_
S ) a Schedules a periodic piece of work.
Args:
period: Period in seconds or timedelta for running the
work periodically.
action: Action to be executed.
state: [Optional] Initial state passed to the action upon
the first iteration.
Returns:
The disposable object used to cancel the scheduled
recurring action (best effort).
schedule_periodicFN)r r c
sX rd S z
| W S t k
rR } z"d|s4 W Y d S d }~X Y nX d S )NT) Exceptionr Zdispose)r exr Zdispfailedr r r periodic s
z2CatchScheduler.schedule_periodic..periodicr! )N) getattrr callableNotImplementedErrorr r r r r
r) Z
disposable)r r( r r r) r. r r r, r r) i s $
z CatchScheduler.schedule_periodic)r r c C s t || jS N)r r )r r r r r _clone s zCatchScheduler._clone)r r c s, | t jtt tt j d fdd }|S )N)r r r c
sP z | |W S tk
rJ } z|s0 t W Y S d }~X Y nX d S r2 )_get_recursive_wrapperr* r r
)r r r+ r parentr r wrapped_action s
z,CatchScheduler._wrap..wrapped_action)r r r r DisposableBase)r r r7 r r5 r r" s
zCatchScheduler._wrapc C s< | j d ks| j|kr6|| _| |}||_||_ || _ | j S r2 )r r r3 )r r wrapperr r r r4 s
z%CatchScheduler._get_recursive_wrapper)N)N)N)N) __name__
__module__ __qualname__r r r r* boolr propertyr r r ZScheduledActionr r r8 r# Z RelativeTimer% Z AbsoluteTimer' ZScheduledPeriodicActionr) r3 r" r4
__classcell__r r r r r
sL , r N)r r r r r r Z reactivexr Zreactivex.abc.schedulerr Zreactivex.disposabler
r Zperiodicschedulerr
r r r r r r s