🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 23:26:13 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
eventloop
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/__pycache__
🔄 Refresh
✏️
Editing: ioloopscheduler.cpython-38.pyc
Read Only
U v�ie � @ s~ d dl Z d dlmZ d dlmZmZmZ d dlmZmZ d dlm Z m Z m Z ddl m Z ed�Ze �d �ZG d d � d e �ZdS ) � N)�datetime)�Any�Optional�TypeVar)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStateZRxc s� e Zd ZdZedd�� 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 �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 Z add_callbackr r )r r r r" r# r r r �schedule$ s zIOLoopScheduler.schedule)�duetimer r r c sz �� |�}|dkr �j� �d�S t� �dd�� ���fdd� }t�d|� �j�||��dd���fdd � }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). g r Nr c s �j � �d��_d S r r r )r r! r r r r r" Y s z3IOLoopScheduler.schedule_relative.<locals>.intervalz timeout: %sc s � j ��� � j ��� d S )N)r Zremove_timeoutr )r �timerr r r# _ s z2IOLoopScheduler.schedule_relative.<locals>.dispose) Z to_secondsr$ r �log�debugr � call_laterr r )r r% r r �secondsr" r# r )r r! r r r& r �schedule_relativeA s z!IOLoopScheduler.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_datetimer+ �now)r r% r r r r r �schedule_absolutee s z!IOLoopScheduler.schedule_absoluter c C s | � | j�� �S )z�Represents a notion of time for this scheduler. Tasks being scheduled on a scheduler will adhere to the time denoted by this property. Returns: The scheduler's current time, as a datetime instance. )r, r �time)r r r r r- z s zIOLoopScheduler.now)N)N)N)�__name__� __module__� __qualname__�__doc__r r r ZScheduledActionr r r ZDisposableBaser$ Z RelativeTimer+ Z AbsoluteTimer. �propertyr r- � __classcell__r r r r r s0 � � ! �� ( �� r )�loggingr r r r r Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r � getLoggerr' r r r r r �<module> s
💾 Save Changes
❌ Cancel