U
vi
@ s d dl Z d dlZd dlmZmZmZ d dlmZmZ d dlm Z d dl
m Z ddl m
Z
ddlmZ ed Ze d
ZG d d d e
ZdS )
N)AnyOptionalTypeVar)abctyping)
PriorityQueue)
DELTA_ZERO )PeriodicScheduler)
ScheduledItem_TStateZRxc s e Zd ZdZed fdd Zdeje e e e
j dddZ dej
eje e e e
j d d
d Zdejeje e e e
j d d d
ZddddZ ZS )PyGameSchedulerzA scheduler that schedules works for PyGame.
Note that this class expects the caller to invoke run() repeatedly.
http://www.pygame.org/docs/ref/time.html
http://www.pygame.org/docs/ref/event.html)pygamec s& t || _t | _t | _dS )zCreate a new PyGameScheduler.
Args:
pygame: The PyGame module to use; typically, you would get this by
import pygame
N)super__init__Z_pygame threadingLock_lockr _queue)selfr __class__ ]/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/pygamescheduler.pyr s
zPyGameScheduler.__init__N)actionstatereturnc C s t d| | j| j||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).
z"PyGameScheduler.schedule(state=%s)r )logdebugschedule_absolutenow)r r r r r r schedule& s zPyGameScheduler.schedule)duetimer r r c C s& t t| |}| j| j| ||dS )at 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 )maxr Z to_timedeltar r! )r r# r r r r r schedule_relative7 s z!PyGameScheduler.schedule_relativec C s< | |}t| |||}| j | j| W 5 Q R X |jS )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 r r enqueueZ
disposable)r r# r r sir r r r K s
z!PyGameScheduler.schedule_absolute)r c C sb | j r^| j: | j }|j| j }|tkr8W 5 Q R q^| j }W 5 Q R X | s | q d S )N) r r peekr# r! r dequeueZ is_cancelledZinvoke)r itemdiffr r r rune s
zPyGameScheduler.run)N)N)N)__name__
__module__ __qualname____doc__r r r ZScheduledActionr r r ZDisposableBaser" Z RelativeTimer% Z AbsoluteTimer r-
__classcell__r r r r r
s. r
)loggingr r r r r Z reactivexr Zreactivex.internalr Z reactivex.internal.constantsr Zperiodicschedulerr
Z
scheduleditemr r getLoggerr r
r r r r s