🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 10:31:52 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/__pycache__
🔄 Refresh
✏️
Editing: timeoutscheduler.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZ d dlmZmZmZ d dlmZ d dl m Z mZ d dl m Z m Z mZ ddlmZ ed�ZG d d � d e�Zd gZd S ) � )�Lock�Timer)�MutableMapping�Optional�TypeVar)�WeakKeyDictionary)�abc�typing)�CompositeDisposable� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStatec s� e Zd ZU dZe� Ze� Zee d f e d< e d d�� fdd� �Z d d�dd�Z deje ee ejd �d d �Zdejeje ee ejd �d d�Zdejeje ee ejd �dd�Z� ZS )�TimeoutSchedulerz5A scheduler that schedules work via a timed callback.�_global��returnc sP t j�@ zt j| }W n* tk r@ t� �| �}|t j| < Y nX W 5 Q R X |S �N)r �_lockr �KeyError�super�__new__)�cls�self�� __class__� �U/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/timeoutscheduler.py� singleton s zTimeoutScheduler.singletonc C s | � � S r )r )r r r r r ! s zTimeoutScheduler.__new__N)�action�stater c sV t � �dd�� ���fdd� }td|��d�_��� 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). Nr c s �� � ���_d S r �Z invoke_actionZ disposabler �r �sadr r! r r �interval4 s z+TimeoutScheduler.schedule.<locals>.intervalr Tc s � � � d S r ��cancelr ��timerr r �dispose; s z*TimeoutScheduler.schedule.<locals>.dispose)r r �daemon�startr r )r r r! r% r* r �r r$ r r! r) r �schedule$ s zTimeoutScheduler.schedule)�duetimer r! r c st �� |�}|dkr ��� ��S t� �dd�� ���fdd� }t||��d�_��� 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 Nr c s �� � ���_d S r r" r r# r r r% X s z4TimeoutScheduler.schedule_relative.<locals>.intervalTc s � � � d S r r& r r( r r r* _ s z3TimeoutScheduler.schedule_relative.<locals>.dispose)Z to_secondsr. r r r+ r, r r )r r/ r r! �secondsr% r* r r- r �schedule_relative@ s z"TimeoutScheduler.schedule_relativec C s | � |�}| �|| j ||�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). )� to_datetimer1 �now)r r/ r r! r r r �schedule_absoluted s z"TimeoutScheduler.schedule_absolute)N)N)N)�__name__� __module__� __qualname__�__doc__r r r r r �type�__annotations__� classmethodr r r ZScheduledActionr r ZDisposableBaser. r Z RelativeTimer1 Z AbsoluteTimer4 � __classcell__r r r r r s4 � � �� ( ��r N)� threadingr r r r r r �weakrefr Z reactivexr Zreactivex.disposabler r r Zperiodicschedulerr r r �__all__r r r r �<module> s i
💾 Save Changes
❌ Cancel