🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 15:05:43 | 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: immediatescheduler.cpython-38.pyc
Read Only
U v�i1 � @ s| d dl mZ d dlmZmZmZ d dlmZ d dlm Z mZ d dl m Z d dl m Z ddlmZ ed �ZG d d � d e�Zd S ) � )�Lock)�MutableMapping�Optional�TypeVar)�WeakKeyDictionary)�abc�typing)� DELTA_ZERO)�WouldBlockException� )� Scheduler�_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 )�ImmediateSchedulera' Represents an object that schedules units of work to run immediately, on the current thread. You're not allowed to schedule timeouts using the ImmediateScheduler since that will block the current thread while waiting. Attempts to do so will raise a :class:`WouldBlockException`. �_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__� �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/immediatescheduler.py� singleton s z ImmediateScheduler.singletonc C s | � � S r )r )r r r r r " s zImmediateScheduler.__new__N)�action�stater c C s | � ||�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). )� invoke_action)r r r r r r �schedule% s zImmediateScheduler.schedule)�duetimer r r c C s$ | � |�}|tkrt� �| �||�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). )Z to_timedeltar r r �r r! r r r r r �schedule_relative5 s z$ImmediateScheduler.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_datetimer# �nowr" r r r �schedule_absoluteM s z$ImmediateScheduler.schedule_absolute)N)N)N)�__name__� __module__� __qualname__�__doc__r r r r r �type�__annotations__� classmethodr r r ZScheduledActionr r r ZDisposableBaser Z RelativeTimer# Z AbsoluteTimer& � __classcell__r r r r r s4 � � �� ��r N)� threadingr r r r r �weakrefr Z reactivexr Z reactivex.internal.constantsr Z reactivex.internal.exceptionsr Z schedulerr r r r r r r �<module> s
💾 Save Changes
❌ Cancel