🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 07:22:17 | 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: catchscheduler.cpython-38.pyc
Read Only
U v�i� � @ sx d dl m Z d dlmZmZmZmZ d dlmZmZ d dlm Z d dl m Z m Z ddl mZ ed�ZG d d � d e�Zd S ) � )�datetime)�Callable�Optional�TypeVar�cast)�abc�typing)� SchedulerBase)� Disposable�SingleAssignmentDisposable� )�PeriodicScheduler�_TStatec s e Zd Zejeegef dd�� fdd� Ze e d�dd��Z de j e ee ejd�d d �Zd e je j e ee ejd �d d �Zd e je j e ee ejd �dd�Zd e je je ee ejd�dd�Zejd d�dd�Ze j e e j e d�dd�Zed d�dd�Z� ZS ) �CatchSchedulerN)� scheduler�handler�returnc s& t � �� || _|| _d| _d| _dS )a� Wraps a scheduler, passed as constructor argument, adding exception handling for scheduled actions. The handler should return True to indicate it handled the exception successfully. Falsy return values will be taken to indicate that the exception should be escalated (raised by this scheduler). Args: scheduler: The scheduler to be wrapped. handler: Callable to handle exceptions raised by wrapped scheduler. N)�super�__init__� _scheduler�_handler�_recursive_original�_recursive_wrapper)�selfr r �� __class__� �S/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/catchscheduler.pyr s zCatchScheduler.__init__)r c C s | j jS )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 �now)r r r r r " s zCatchScheduler.now)�action�stater c C s | � |�}| jj||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 )�_wrapr �schedule)r r r r r r r# . s zCatchScheduler.schedule)�duetimer r r c C s | � |�}| jj|||d�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" r �schedule_relative�r r$ r r r r r r% ? s z CatchScheduler.schedule_relativec C s | � |�}| jj|||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! )r" r �schedule_absoluter& r r r r' T s z CatchScheduler.schedule_absolute)�periodr r r c sh t �jd�}t|�st�t� �d�dtt tt d�� ���fdd� }tt�j�}|j |||d��_ �S ) a� Schedules a periodic piece of work. Args: period: Period in seconds or timedelta for running the work periodically. action: Action to be executed. state: [Optional] Initial state passed to the action upon the first iteration. Returns: The disposable object used to cancel the scheduled recurring action (best effort). �schedule_periodicFN)r r c sX �rd S z � | �W S t k rR } z"d���|�s4� ��� W Y �d S d }~X Y nX d S )NT)� Exceptionr Zdispose)r �ex�r Zdisp�failedr r r �periodic� s z2CatchScheduler.schedule_periodic.<locals>.periodicr! )N) �getattrr �callable�NotImplementedErrorr r r r r r) Z disposable)r r( r r r) r. r r r, r r) i s $ z CatchScheduler.schedule_periodic)r r c C s t || j�S �N)r r )r r r r r �_clone� s zCatchScheduler._clone)r r c s, | �t jtt tt j d�� �fdd� }|S )N)r r r c sP z� �� | �|�W S tk rJ } z��|�s0� t� W Y �S d }~X Y nX d S r2 )�_get_recursive_wrapperr* r r )r r r+ �r �parentr r �wrapped_action� s z,CatchScheduler._wrap.<locals>.wrapped_action)r r r r �DisposableBase)r r r7 r r5 r r" � s � zCatchScheduler._wrapc C s< | j d ks| j|kr6|| _| �|�}||_||_ || _ | j S r2 )r r r3 )r r �wrapperr r r r4 � s z%CatchScheduler._get_recursive_wrapper)N)N)N)N) �__name__� __module__� __qualname__r r r r* �boolr �propertyr r r ZScheduledActionr r r8 r# Z RelativeTimer% Z AbsoluteTimer' ZScheduledPeriodicActionr) r3 r" r4 � __classcell__r r r r r sL � � � �� �� �� ,� r N)r r r r r r Z reactivexr Zreactivex.abc.schedulerr Zreactivex.disposabler r Zperiodicschedulerr r r r r r r �<module> s
💾 Save Changes
❌ Cancel