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

twistedscheduler.cpython-38.pyc

����ܒi-
����������������������@���s~���d�dl�Z�d�dlmZ�d�dlmZmZmZ�d�dlmZmZ�d�dlm	Z	m
Z
mZ�ddlm
Z
�ed�Ze��d	�ZG�d
d��de
�ZdS�)�����N)�datetime)�Any�Optional�TypeVar)�abc�typing)�CompositeDisposable�
Disposable�SingleAssignmentDisposable����)�PeriodicScheduler�_TStateZRxc�����������������������s����e�Zd�ZdZedd���fdd�Zdeje�e	e�e
jd�dd�Zdej
eje�e	e�e
jd	�d
d�Zdejeje�e	e�e
jd	�dd
�Zeed�dd��Z���ZS�)�TwistedSchedulerzAA scheduler that schedules work via the Twisted reactor mainloop.N)�reactor�returnc��������������������s���t�������||�_dS�)z�Create a new TwistedScheduler.

Args:
            reactor: The reactor to use; typically, you would get this
                by from twisted.internet import reactor
        N)�super�__init__�_reactor)�selfr�����	__class__���_/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloop/twistedscheduler.pyr������s����
zTwistedScheduler.__init__)�action�stater���c�����������������C���s���|�j�d||d�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).
        ����������r���)�schedule_relative)r���r���r���r���r���r����schedule ���s����zTwistedScheduler.schedule)�duetimer���r���r���c��������������������sh���t�d��|��}t���dd������fdd�}t�d|���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���N�r���c����������������������s���������_�d�S��N)Z
disposabler���)r����sadr���r���r���r����intervalF���s����z4TwistedScheduler.schedule_relative.<locals>.intervalztimeout: %sc����������������������s�����j�s������d�S�r!���)�called�cancelr���)�timerr���r����disposeL���s����z3TwistedScheduler.schedule_relative.<locals>.dispose)	�maxZ
to_secondsr
����log�debugr���Z	callLaterr���r	���)r���r���r���r����secondsr#���r'���r���)r���r"���r���r���r&���r���r���0���s����z"TwistedScheduler.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_absoluteR���s����
z"TwistedScheduler.schedule_absoluter ���c�����������������C���s���|���t|�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,����floatr���r+���)r���r���r���r���r-���g���s����
zTwistedScheduler.now)N)N)N)�__name__�
__module__�__qualname__�__doc__r���r���r���ZScheduledActionr
���r���r���ZDisposableBaser���ZRelativeTimer���ZAbsoluteTimer.����propertyr���r-����
__classcell__r���r���r���r���r������s0����������&���r���)�loggingr���r���r���r���r���Z	reactivexr���Zreactivex.disposabler���r	���r
���Zperiodicschedulerr���r
����	getLoggerr)���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	607 B	root/root	0644	2026-02-16 08:57:59
asyncioscheduler.cpython-38.pyc	text/x-bytecode.python	4.48 KB	root/root	0644	2026-02-16 08:57:59
asynciothreadsafescheduler.cpython-38.pyc	text/x-bytecode.python	5.42 KB	root/root	0644	2026-02-16 08:57:59
eventletscheduler.cpython-38.pyc	text/x-bytecode.python	4.39 KB	root/root	0644	2026-02-16 08:57:59
geventscheduler.cpython-38.pyc	text/x-bytecode.python	4.42 KB	root/root	0644	2026-02-16 08:57:59
ioloopscheduler.cpython-38.pyc	text/x-bytecode.python	4.59 KB	root/root	0644	2026-02-16 08:57:59
twistedscheduler.cpython-38.pyc	text/x-bytecode.python	4 KB	root/root	0644	2026-02-16 08:57:59

Team Anon Force

https://t.me/Professor6T9x