🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 09:10:39 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
mainloop
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/__pycache__
🔄 Refresh
✏️
Editing: wxscheduler.cpython-38.pyc
Read Only
U v�i� � @ sz d dl Z d dlmZmZmZmZmZ d dlmZmZ d dl m Z m Z m Z ddl mZ ed�Ze �d�ZG d d � d e�ZdS ) � N)�Any�Optional�Set�TypeVar�cast)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStateZRxc s� e Zd ZdZedd�� fdd� Zdd�dd�Zdejej e e e e e jd �d d �Zdeje e e e jd �dd�Zdejeje e e e jd�dd�Zdejeje e e e jd�dd�Zd ejeje e e e jd�dd�Z� ZS ) � WxSchedulerz&A scheduler for a wxPython event loop.N)�wx�returnc s: t � �� || _| jj}G dd� d|�}|| _t� | _dS )z�Create a new WxScheduler. Args: wx: The wx module to use; typically, you would get this by import wx c s4 e Zd Zejdd�� fdd� Zdd�dd�Z� ZS )z#WxScheduler.__init__.<locals>.TimerN)�callbackr c s t � �� || _d S �N)�super�__init__r )�selfr �� __class__� �Y/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/wxscheduler.pyr " s z,WxScheduler.__init__.<locals>.Timer.__init__�r c S s | � � d S r )r )r r r r �Notify& s z*WxScheduler.__init__.<locals>.Timer.Notify)�__name__� __module__� __qualname__r �Actionr r � __classcell__r r r r �Timer! s r" N)r r �_wxr" � _timer_class�set�_timers)r r Z timer_classr" r r r r s zWxScheduler.__init__r c C s | j D ] }|�� qdS )z�Cancel all scheduled actions. Should be called when destroying wx controls to prevent accessing dead wx objects in actions that might be pending. N)r& �Stop�r �timerr r r � cancel_all, s zWxScheduler.cancel_allF)�time�action�state�periodicr c s� ��t � �d d�� ����fdd� }tdt��|�d ��}t�d|� ��|���j�� rn�j |� d� n�jj �j |� d� �j � �� d d���fdd � }t �t|��S ) Nr c s6 �rt tjt � ����nt tjt � �����_d S r )r r �ScheduledPeriodicActionr �ScheduledAction� disposabler )r, r. �sad� schedulerr- r r �interval@ s �z/WxScheduler._wxtimer_schedule.<locals>.interval� g @�@ztimeout wx: %s)ZoneShotc s �� � � j��� d S r )r' r& �remover r( r r �disposeU s z.WxScheduler._wxtimer_schedule.<locals>.dispose)r �max�intZ to_seconds�log�debugr$ r# Z IsMainThreadZStart� CallAfterr& �addr r )r r+ r, r- r. r4 �msecsr7 r )r, r. r2 r3 r r- r) r �_wxtimer_schedule5 s z WxScheduler._wxtimer_schedule)r, r- r c sP t � �d�dd�� ����fdd� }�j�|� dd��fdd� }t�t|��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). FNr c s �s� ����_ d S r )r1 r �r, � is_disposedr2 r r- r r � invoke_actionk s z+WxScheduler.schedule.<locals>.invoke_actionc s d� d S )NTr r )rA r r r7 q s z%WxScheduler.schedule.<locals>.dispose)r r# r< r r )r r, r- rB r7 r r@ r �schedule[ s zWxScheduler.schedule)�duetimer, r- r c C s | j |||d�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). �r- �r? �r rD r, r- r r r �schedule_relativew s z WxScheduler.schedule_relativec C s | � |�}| j|| j ||d�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). rE )� to_datetimer? �nowrG r r r �schedule_absolute� s z WxScheduler.schedule_absolute)�periodr, r- r c C s | j |||dd�S )a� Schedules a periodic piece of work to be executed in the loop. Args: period: Period in seconds for running the work repeatedly. 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). T)r- r. rF )r rL r, r- r r r �schedule_periodic� s z WxScheduler.schedule_periodic)NF)N)N)N)N)r r r �__doc__r r r* r ZAbsoluteOrRelativeTimeZ ScheduledSingleOrPeriodicActionr r �boolr ZDisposableBaser? r0 rC Z RelativeTimerH Z AbsoluteTimerK r/ rM r! r r r r r sN �� ' � � �� �� ��r )�loggingr r r r r r Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r � getLoggerr: r r r r r �<module> s
💾 Save Changes
❌ Cancel