U
vi1 @ s| d dl mZ d dlmZmZmZ d dlmZ d dlm Z mZ d dl
m Z d dl m
Z
ddlmZ ed ZG d
d d eZd S )
)Lock)MutableMappingOptionalTypeVar)WeakKeyDictionary)abctyping)
DELTA_ZERO)WouldBlockException ) Scheduler_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 )ImmediateSchedulera' Represents an object that schedules units of work to run immediately,
on the current thread. You're not allowed to schedule timeouts using the
ImmediateScheduler since that will block the current thread while waiting.
Attempts to do so will raise a :class:`WouldBlockException`.
_global)returnc 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__ W/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/immediatescheduler.py singleton s z ImmediateScheduler.singletonc C s | S r )r )r r r r r " s zImmediateScheduler.__new__N)actionstater c C s | ||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).
)
invoke_action)r r r r r r schedule% s zImmediateScheduler.schedule)duetimer r r c C s$ | |}|tkrt | ||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).
)Z to_timedeltar r
r r r! r r r r r schedule_relative5 s
z$ImmediateScheduler.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_datetimer# nowr" r r r schedule_absoluteM s
z$ImmediateScheduler.schedule_absolute)N)N)N)__name__
__module__ __qualname____doc__r r r r r type__annotations__ classmethodr r r ZScheduledActionr
r r ZDisposableBaser Z RelativeTimer# Z AbsoluteTimer&
__classcell__r r r r r s4
r N) threadingr r r r r weakrefr Z reactivexr Z reactivex.internal.constantsr Z reactivex.internal.exceptionsr
Z schedulerr r
r r r r r s