🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 03:28:38 | 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: asynciothreadsafescheduler.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlZd dlmZ d dlmZmZmZ d dlm Z mZ d dl m Z m Z m Z ddlmZ ed�Ze�d �ZG d d � d e�ZdS ) � N)�Future)�List�Optional�TypeVar)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�AsyncIOScheduler�_TStateZRxc @ s� e Zd ZdZdeje ee ej d�dd�Z dej eje ee ej d�dd�Z dej eje ee ej d�d d �Zed �d d �ZdS )�AsyncIOThreadSafeSchedulerz�A scheduler that schedules work via the asyncio mainloop. This is a subclass of AsyncIOScheduler which uses the threadsafe asyncio methods. N)�action�state�returnc sL 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 disposable� �r �sad�selfr r �i/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/asynciothreadsafescheduler.py�interval( s z5AsyncIOThreadSafeScheduler.schedule.<locals>.intervalc sF �� � r��� d S t� � d d�� �fdd� } �j�| � � �� d S )Nr c s �� � � �d� d S �Nr )�cancel� set_resultr )�future�handler r � cancel_handle4 s zKAsyncIOThreadSafeScheduler.schedule.<locals>.dispose.<locals>.cancel_handle)� _on_self_loop_or_not_runningr r �_loop�call_soon_threadsafe�result�r! �r r )r r �dispose- s z4AsyncIOThreadSafeScheduler.schedule.<locals>.dispose)r r# r$ r r )r r r r r( r )r r r r r r �schedule s z#AsyncIOThreadSafeScheduler.schedule)�duetimer r r c s� �� |���dkr �j� �d�S t� �dd�� ���fdd� �g �dd�����fdd� }���j�|�� 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 r Nr c s �j � �d��_d S r r r r r r r T s z>AsyncIOThreadSafeScheduler.schedule_relative.<locals>.intervalc s � � �j����� d S �N)�appendr# � call_laterr )r r �secondsr r r �stage2[ s z<AsyncIOThreadSafeScheduler.schedule_relative.<locals>.stage2c sV d d��fdd� � �� � r$� � d S t� �d d�� �fdd� } �j�| � ��� d S )Nr c s6 z � � � �� � � � �� W n tk r0 Y nX d S r+ )�popr � Exceptionr )r r r �do_cancel_handlesa s zXAsyncIOThreadSafeScheduler.schedule_relative.<locals>.dispose.<locals>.do_cancel_handlesc s � � �� d� d S r )r r �r2 r r r r! n s zTAsyncIOThreadSafeScheduler.schedule_relative.<locals>.dispose.<locals>.cancel_handle)r" r r# r$ r% r& r' r3 r r( ` s z=AsyncIOThreadSafeScheduler.schedule_relative.<locals>.dispose)Z to_secondsr) r r, r# r$ r r )r r* r r r/ r( r )r r r r r. r r r �schedule_relative= s z,AsyncIOThreadSafeScheduler.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_datetimer4 �now)r r* r r r r r �schedule_absolutew s z,AsyncIOThreadSafeScheduler.schedule_absoluter c C s> | j �� sdS d}z t�� }W n tk r2 Y nX | j |kS )z� Returns True if either self._loop is not running, or we're currently executing on self._loop. In both cases, waiting for a future to be resolved on the loop would result in a deadlock. TN)r# � is_running�asyncio�get_event_loop� RuntimeError)r � current_loopr r r r" � s z7AsyncIOThreadSafeScheduler._on_self_loop_or_not_running)N)N)N)�__name__� __module__� __qualname__�__doc__r ZScheduledActionr r r ZDisposableBaser) Z RelativeTimer4 Z AbsoluteTimer7 �boolr" r r r r r s, � � ( �� > �� r )r9 �logging�concurrent.futuresr r r r r Z reactivexr Zreactivex.disposabler r r Zasyncioschedulerr r � getLogger�logr r r r r �<module> s
💾 Save Changes
❌ Cancel