🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:19:00 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _delay.cpython-38.pyc
Read Only
U v�ir � @ s� d dl m Z d dlmZmZmZmZmZ d dlmZm Z m Z d dlm Z d dlmZ d dl mZmZmZ d dlmZ d dlmZ d d lmZ d d lmZ ed �Zde e ejee j e e d�dd�Z dejee j ee e ge e f d�dd�Z dgZ d S )� )�datetime)�Any�Callable�List�Optional�TypeVar)� Notification� Observable�abc)� operators)�typing)�CompositeDisposable� MultipleAssignmentDisposable�SerialDisposable)� DELTA_ZERO)�OnError)�TimeoutScheduler� )� Timestamp�_TN)�source�duetime� scheduler�returnc s. dt jt tt j d�� ��fdd� }t|�S )N)�observer� scheduler_c s� � p|pt �� � t�t�r,� ���� j �n � ����t� �d �dg�dg�g �tt t d d�� �������� f dd� }� � t � � t �� �j|� d�}t|��S )NF)� notificationr c s� d}� j �f t| jt�r@�d d �= ��| � | jj�� d }n,��t| j| j� d�� �d }d�d< W 5 Q R X |rʈr����� n@t � ���_ dt j t d�� ������ � fdd� � ���� ��_ d S ) NFr )�value� timestampT)r �statec s� �rd S �j �� d�d< d }�r<�d j| jkr<��d�j}|rJ|��� |sqRqd}d}�r~d}�d j| j }tt|�}nd�d< �}d�d< W 5 Q R X |r���|� n|r�| � |� ��_ d S )NTr F) �lockr �now�popr �accept�maxr �on_error�schedule_relative� disposable)r r �resultZshould_continueZrecurse_duetime�diff�ex)�action�active� exception�madr �queue�runningr � �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_delay.pyr+ G s6 �zMobservable_delay_timespan.<locals>.subscribe.<locals>.on_next.<locals>.action)N)r � isinstancer r �appendr- r r r% r r' r � SchedulerBaser r& )r Z should_run) � _schedulerr, � cancelable�duetime_r- r r/ r0 r )r+ r. r2 �on_next, s, �� &$z=observable_delay_timespan.<locals>.subscribe.<locals>.on_next)r )r Z singletonr3 r � to_datetimer! Z to_timedeltar r r r �pipe�opsZ materializer � subscriber )r r r9 Z subscription�r r r )r6 r, r7 r8 r- r r/ r0 r2 r= s$ ,A� �z,observable_delay_timespan.<locals>.subscribe)N)r Z ObserverBaser r r5 r )r r r r= r1 r> r2 �observable_delay_timespan s � �Zr? )r r r c s" t t t t d�� �fdd� }|S )N)r r c s t | � ��S )a! Time shifts the observable sequence. A partially applied delay operator function. Examples: >>> res = delay(source) Args: source: The observable sequence to delay. Returns: A time-shifted observable sequence. )r? )r �r r r1 r2 �delayz s zdelay_.<locals>.delay)r r )r r rA r1 r@ r2 �delay_w s rB )N)N) r r r r r r r Z reactivexr r r r r< Zreactivex.disposabler r r Z reactivex.internal.constantsr Zreactivex.notificationr Zreactivex.schedulerr � _timestampr r Z RelativeTimer5 r? rB �__all__r1 r1 r1 r2 �<module> s0 �� c � �
💾 Save Changes
❌ Cancel