🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:17:43 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: timer.cpython-38.pyc
Read Only
U v�i� � @ s d dl m Z d dlmZmZ d dlmZmZmZ d dlmZ d dl m Z d dl m Z dej eej ee d�d d �Zdejejeej ee d �d d �Zdejeej ee d�dd�Zdejejeej ee d �dd�Zdejeej eej ee d �dd�ZdgZdS )� )�datetime)�Any�Optional)� Observable�abc�typing)� MultipleAssignmentDisposable)�TimeoutScheduler)�PeriodicSchedulerN)�duetime� scheduler�returnc s0 dt jt tt j t jd�� �fdd� }t|�S )N��observer� scheduler_r c s4 �p|pt �� }tjtd d�� fdd� }|��|�S )N�r �stater c s � � d� � �� d S �Nr ��on_nextZ on_completed�r r �r � �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/timer.py�action s z8observable_timer_date.<locals>.subscribe.<locals>.action)r � singletonr � SchedulerBaser �schedule_absolute�r r � _schedulerr �r r r r � subscribe s �z(observable_timer_date.<locals>.subscribe)N�r � ObserverBase�intr r �DisposableBaser �r r r! r r r �observable_timer_date s � � r' )r �periodr r c s2 dt jt tt j t jd�� ��fdd� }t|�S )Nr c s| �p|pt �� }t�t�s*|j|��� �td|�����t� ���d�t j t d d�� �����fdd� � |� �� ��_ �S )N� r r c sV �dkr2| j }�| ��� ��|kr2|| ��� ����� �d7 �| ��� ��_d S )Nr) � )�now� to_timedeltar r � disposable)r r r+ �r �count�dtZmadr �pr r r 0 s zFobservable_timer_duetime_and_period.<locals>.subscribe.<locals>.action)r r � isinstancer r+ r, �max� to_secondsr r r r r r- )r r r �r r( r r. r r! " s "z6observable_timer_duetime_and_period.<locals>.subscribe)Nr" �r r( r r! r r5 r �#observable_timer_duetime_and_period s � � r7 c s0 dt jt tt j t jd�� �fdd� }t|�S )Nr c sP �p|pt �� }|���}tjtd d�� fdd� }|dkrD|�|�S |�||�S )Nr c s � � d� � �� d S r r r r r r r M s z<observable_timer_timespan.<locals>.subscribe.<locals>.actionr) )r r r4 r r r ZscheduleZschedule_relative)r r r �dr r r r r! G s z,observable_timer_timespan.<locals>.subscribe)Nr" r& r r r �observable_timer_timespanD s � �r9 c sD | � kr8dt jt tt j t jd�� �fdd� }t|�S t| � ��S )Nr c sP �p|pt �� }dtt tt d�� fdd� }t|t�s@td��|j�|dd�S )N)r/ r c s | d k r� � | � | d S d S )Nr* )r )r/ r r r r g s zGobservable_timer_timespan_and_period.<locals>.subscribe.<locals>.actionz"Sceduler must be PeriodicSchedulerr )r )N)r r r r$ r2 r � ValueErrorZschedule_periodicr �r( r r r r! _ s � z7observable_timer_timespan_and_period.<locals>.subscribe)N)r r# r$ r r r% r r7 r6 r r; r �$observable_timer_timespan_and_periodX s ��r< c C sF t | t�r(|d kr t| |�S t| ||�S |d kr:t| |�S t| ||�S )N)r2 r r' r7 r9 r< r5 r r r �timer_u s r= )N)N)N)N)NN)r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr Z%reactivex.scheduler.periodicschedulerr Z AbsoluteTimer r$ r' ZAbsoluteOrRelativeTimer7 Z RelativeTimer9 r< r= �__all__r r r r �<module> sP � � �� ( � � �� ��
💾 Save Changes
❌ Cancel