🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:23:37 | 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: _timeout.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZ d dlmZmZmZmZmZ d dl m Z m Z m Z m Z mZ d dlmZmZmZ d dlmZ ed�Zd ejeee e d f ee j ee e ge e f d �d d �ZdS )� )�Future)�datetime)�Any�Callable�Optional�TypeVar�Union)� Observable�abc� from_future�throw�typing)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable)�TimeoutScheduler�_TNz Future[_T])�duetime�other� scheduler�returnc sL |pt td��}t|t�r$t|��n|�tt tt d�� ��fdd� }|S )N�Timeout)�sourcer c s4 dt jt tt j t jd����� fdd� }t|�S )a\ Returns the source observable sequence or the other observable sequence if duetime elapses. Examples: >>> res = timeout(source) Args: source: Source observable to timeout Returns: An observable sequence switching to the other sequence in case of a timeout. N)�observer� scheduler_r c s� � p|pt �� �dg�dg� t� }t� �t� �|�_d d�� �������fdd� ��� td d�� ���fdd� }td d �� ��fd d � }d d�� ��fd d � }� j||||d�|_t���S )NFr )r c sV �d � dt jtd��� ����fdd� } t�t�rD���| ��_n���| ��_d S )Nr )r �statec s0 � d �k�d< �d }|r,�j �| d��_d S )Nr �r )� subscribe� disposable)r r Z timer_wins)�_id�my_id�obsr � subscription�switched� �M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeout.py�action< s �zRtimeout_.<locals>.timeout.<locals>.subscribe.<locals>.create_timer.<locals>.action)N)r � SchedulerBaser � isinstancer Zschedule_absoluter Zschedule_relative)r& )r � _schedulerr r! r r" r# �timer)r r% � create_timer9 s " zBtimeout_.<locals>.timeout.<locals>.subscribe.<locals>.create_timer)�valuer c s2 �d }|r.� d d7 < �� | � �� d S �Nr � )�on_next)r, Z send_wins)r r+ r r# r$ r% r/ K s z=timeout_.<locals>.timeout.<locals>.subscribe.<locals>.on_next)�errorr c s, �d }|r(� d d7 < �� | � d S r- )�on_error)r0 Z on_error_wins�r r r# r$ r% r1 R s z>timeout_.<locals>.timeout.<locals>.subscribe.<locals>.on_errorc s* �d } | r&� d d7 < �� � d S r- )� on_completed)Zon_completed_winsr2 r$ r% r3 X s zBtimeout_.<locals>.timeout.<locals>.subscribe.<locals>.on_completedr ) r Z singletonr r r r � Exceptionr r )r r �originalr/ r1 r3 )r r! r r )r r) r+ r r" r# r* r% r + s& �z,timeout_.<locals>.timeout.<locals>.subscribe)N)r Z ObserverBaser r r' ZDisposableBaser )r r �r r! r )r r% �timeout s ��8ztimeout_.<locals>.timeout)r r4 r( r r r r )r r r r7 r$ r6 r% �timeout_ s Ir8 )NN)�asyncior r r r r r r r Z reactivexr r r r Zreactivex.disposabler r r Zreactivex.schedulerr r ZAbsoluteOrRelativeTimer' r8 r$ r$ r$ r% �<module> s ��
💾 Save Changes
❌ Cancel