🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 04:53:34 | 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: qtscheduler.cpython-38.pyc
Read Only
U v�i| � @ s� d dl Z d dlmZ d dlmZmZmZmZ d dlm Z mZ d dl m Z m Z m Z ddlmZ ed�Ze �e�ZG d d � d e�ZdS ) � N)� timedelta)�Any�Optional�Set�TypeVar)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStatec s� e Zd ZdZed�� fdd� Zdeje e e e j d�dd�Z dej eje e e e j d �d d �Zdejeje e e e j d �d d �Zdej eje e e e j d�dd�Z� ZS )� QtSchedulerz+A scheduler for a PyQt5/PySide2 event loop.)�qtcorec s t � �� || _t� | _dS )z�Create a new QtScheduler. Args: qtcore: The QtCore instance to use; typically you would get this by either import PyQt5.QtCore or import PySide2.QtCore N)�super�__init__�_qtcore�set�_periodic_timers)�selfr �� __class__� �Y/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/qtscheduler.pyr s zQtScheduler.__init__N)�action�state�returnc C s | j d||d�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). g �r )�schedule_relative)r r r r r r �schedule! s zQtScheduler.schedule)�duetimer r r c sx t dt��|�d ��}t� �d�dd�� ����fdd� }t�d|� �jj�||� dd��fd d � }t �t |��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 � @�@FN�r c s �s� ����_ d S �N)Z disposabler �r � is_disposed�sadr r r r � invoke_actionE s z4QtScheduler.schedule_relative.<locals>.invoke_actionzrelative timeout: %smsc s d� d S )NTr r )r& r r �disposeN s z.QtScheduler.schedule_relative.<locals>.dispose) �max�int� to_secondsr �log�debugr �QTimerZ singleShotr r )r r! r r �msecsr( r) r r% r r 0 s z QtScheduler.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). r )� to_datetime�nowr )r r! r r �deltar r r �schedule_absoluteT s z QtScheduler.schedule_absolute)�periodr r r c s� t dt��|�d ��}t� }dd�� �fdd� }t�d|� �j�� ���| � �j � |� �� |� �j � �� ��� dd���fdd � }t|t|��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). r r" Nr# c s � ���d S r$ r r )r r r r �interval} s z/QtScheduler.schedule_periodic.<locals>.intervalzperiodic timeout: %smsc s �� � � j��� ��� d S r$ )�stopr �removeZ deleteLaterr )r �timerr r r) � s z.QtScheduler.schedule_periodic.<locals>.dispose)r* r+ r, r r- r. r r/ Z setSingleShot�timeout�connectZ setIntervalr �add�startr r )r r5 r r r0 r' r6 r) r )r r r r9 r �schedule_periodici s z QtScheduler.schedule_periodic)N)N)N)N)�__name__� __module__� __qualname__�__doc__r r r ZScheduledActionr r r ZDisposableBaser Z RelativeTimer Z AbsoluteTimer4 ZScheduledPeriodicActionr> � __classcell__r r r r r s: � � �� ( �� ��r )�logging�datetimer r r r r r Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r � getLoggerr? r- r r r r r �<module> s
💾 Save Changes
❌ Cancel