byp4a55 professor6T9

Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2

immediatescheduler.cpython-38.pyc

����ܒi1����������������������@���s|���d�dl�mZ�d�dlmZmZmZ�d�dlmZ�d�dlm	Z	mZ�d�dl
mZ�d�dlm
Z
�ddlmZ�ed	�ZG�d
d��de�ZdS�)
�����)�Lock)�MutableMapping�Optional�TypeVar)�WeakKeyDictionary)�abc�typing)�
DELTA_ZERO)�WouldBlockException����)�	Scheduler�_TStatec�����������������������s����e�Zd�ZU�dZe��Ze��Zee	d�f�e
d<�ed�d���fdd��Zd�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����zImmediateScheduler.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).
        )Zto_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 ���ZRelativeTimer#���ZAbsoluteTimer&����
__classcell__r���r���r���r���r������s4���
	����������r���N)�	threadingr���r���r���r���r����weakrefr���Z	reactivexr���Zreactivex.internal.constantsr	���Zreactivex.internal.exceptionsr
���Z	schedulerr���r
���r���r���r���r���r����<module>���s���

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2026-02-16 08:57:59
..	dir	-	root/root	0755	2026-02-16 08:57:59
__init__.cpython-38.pyc	text/x-bytecode.python	949 B	root/root	0644	2026-02-16 08:57:59
catchscheduler.cpython-38.pyc	text/x-bytecode.python	5.87 KB	root/root	0644	2026-02-16 08:57:59
currentthreadscheduler.cpython-38.pyc	text/x-bytecode.python	3.09 KB	root/root	0644	2026-02-16 08:57:59
eventloopscheduler.cpython-38.pyc	text/x-bytecode.python	6.08 KB	root/root	0644	2026-02-16 08:57:59
historicalscheduler.cpython-38.pyc	text/x-bytecode.python	1.04 KB	root/root	0644	2026-02-16 08:57:59
immediatescheduler.cpython-38.pyc	text/x-bytecode.python	3.43 KB	root/root	0644	2026-02-16 08:57:59
newthreadscheduler.cpython-38.pyc	text/x-bytecode.python	4.34 KB	root/root	0644	2026-02-16 08:57:59
periodicscheduler.cpython-38.pyc	text/x-bytecode.python	2.07 KB	root/root	0644	2026-02-16 08:57:59
scheduleditem.cpython-38.pyc	text/x-bytecode.python	1.99 KB	root/root	0644	2026-02-16 08:57:59
scheduler.cpython-38.pyc	text/x-bytecode.python	5.51 KB	root/root	0644	2026-02-16 08:57:59
threadpoolscheduler.cpython-38.pyc	text/x-bytecode.python	1.97 KB	root/root	0644	2026-02-16 08:57:59
timeoutscheduler.cpython-38.pyc	text/x-bytecode.python	4.12 KB	root/root	0644	2026-02-16 08:57:59
trampoline.cpython-38.pyc	text/x-bytecode.python	1.81 KB	root/root	0644	2026-02-16 08:57:59
trampolinescheduler.cpython-38.pyc	text/x-bytecode.python	4.27 KB	root/root	0644	2026-02-16 08:57:59
virtualtimescheduler.cpython-38.pyc	text/x-bytecode.python	6.95 KB	root/root	0644	2026-02-16 08:57:59

Team Anon Force

https://t.me/Professor6T9x