U
vi
@ s d dl mZmZ d dlmZmZmZ d dlmZ d dl m
Z
mZ d dl m Z m
Z
mZ ddlmZ edZG d d
d
eZd
gZd S ) )LockTimer)MutableMappingOptionalTypeVar)WeakKeyDictionary)abctyping)CompositeDisposable
DisposableSingleAssignmentDisposable )PeriodicScheduler_TStatec s e Zd ZU dZe Ze Zee d f e
d< e d d fdd Z d dddZ
deje ee ejd d
d Zdejeje ee ejd d
dZdejeje ee ejd ddZ ZS )TimeoutSchedulerz5A scheduler that schedules work via a timed callback._globalreturnc sP t j@ zt j| }W n* tk
r@ t | }|t j| < Y nX W 5 Q R X |S N)r _lockr KeyErrorsuper__new__)clsself __class__ U/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/timeoutscheduler.py singleton s zTimeoutScheduler.singletonc C s | S r )r )r r r r r ! s zTimeoutScheduler.__new__N)actionstater c sV t dd fdd }td|d_ 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 _d S r Z
invoke_actionZ
disposabler r sadr r! r r interval4 s z+TimeoutScheduler.schedule..intervalr Tc s d S r cancelr timerr r dispose; s z*TimeoutScheduler.schedule..dispose)r r daemonstartr
r )r r r! r% r* r r r$ r r! r) r schedule$ s
zTimeoutScheduler.schedule)duetimer r! r c st |}|dkr S t dd fdd }t||d_ 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 Nr c s _d S r r" r r# r r r% X s z4TimeoutScheduler.schedule_relative..intervalTc s d S r r& r r( r r r* _ s z3TimeoutScheduler.schedule_relative..dispose)Z
to_secondsr. r r r+ r, r
r )r r/ r r! secondsr% r* r r- r schedule_relative@ s
z"TimeoutScheduler.schedule_relativec C s | |}| || j ||S )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).
) to_datetimer1 now)r r/ r r! r r r schedule_absoluted s
z"TimeoutScheduler.schedule_absolute)N)N)N)__name__
__module__ __qualname____doc__r r r r r type__annotations__ classmethodr r r ZScheduledActionr r ZDisposableBaser. r Z RelativeTimer1 Z AbsoluteTimer4
__classcell__r r r r r s4
( r N) threadingr r r r r r weakrefr Z reactivexr Zreactivex.disposabler
r r Zperiodicschedulerr r r __all__r r r r s i