🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 22:17:57 | 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: asyncioscheduler.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZmZ d dlm Z m Z m Z ddl m Z ed�Ze�d �ZG d d � d e �ZdS ) � N)�datetime)�Optional�TypeVar)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStateZRxc s� e Zd ZdZejdd�� fdd� Zdeje e e e j d�dd�Z dejeje e e e j d �d d �Zdejeje e e e j d �d d �Zeed�dd��Z� ZS )�AsyncIOSchedulerz�A scheduler that schedules work via the asyncio mainloop. This class does not use the asyncio threadsafe methods, if you need those please use the AsyncIOThreadSafeScheduler class.N)�loop�returnc s t � �� || _dS )z�Create a new AsyncIOScheduler. Args: loop: Instance of asyncio event loop to use; typically, you would get this by asyncio.get_event_loop() N)�super�__init__�_loop)�selfr �� __class__� �_/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/asyncioscheduler.pyr s zAsyncIOScheduler.__init__)�action�stater c sJ t � �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). N�r c s �j � �d��_d S �N�r �Z invoke_actionZ disposabler �r �sadr r r r �interval1 s z+AsyncIOScheduler.schedule.<locals>.intervalc s � � � d S �N��cancelr ��handler r �dispose6 s z*AsyncIOScheduler.schedule.<locals>.dispose)r r � call_soonr r )r r r r r& r �r r% r r r r �schedule" s zAsyncIOScheduler.schedule)�duetimer r r c sj �� |�}|dkr ��� ��S t� �dd�� ���fdd� }�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). r Nr c s �j � �d��_d S r r r r r r r R s z4AsyncIOScheduler.schedule_relative.<locals>.intervalc s � � � d S r! r" r r$ r r r& W s z3AsyncIOScheduler.schedule_relative.<locals>.dispose)Z to_secondsr) r r � call_laterr r )r r* r r �secondsr r& r r( r �schedule_relative; s z"AsyncIOScheduler.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_absolute\ s z"AsyncIOScheduler.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/ q s zAsyncIOScheduler.now)N)N)N)�__name__� __module__� __qualname__�__doc__�asyncio�AbstractEventLoopr r ZScheduledActionr r r ZDisposableBaser) Z RelativeTimer- Z AbsoluteTimer0 �propertyr r/ � __classcell__r r r r r s0 � � �� % �� r )r6 �loggingr r r r Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r � getLogger�logr r r r r �<module> s
💾 Save Changes
❌ Cancel