🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:24:14 | 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: _timeoutwithmapper.cpython-38.pyc
Read Only
U v�i8 � @ s� d dl mZmZmZmZ d dlZd dlmZmZ d dlm Z m Z m Z ed�Z d eee eeegee f eee eee gee f d�dd�Z dgZdS ) � )�Any�Callable�Optional�TypeVarN)� Observable�abc)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable�_T)� first_timeout�timeout_duration_mapper�other�returnc sB | p t �� � |p t �td���tt tt d�� ��fdd� }|S )a Returns the source observable sequence, switching to the other observable sequence if a timeout is signaled. res = timeout_with_mapper(reactivex.timer(500)) res = timeout_with_mapper(reactivex.timer(500), lambda x: reactivex.timer(200)) res = timeout_with_mapper( reactivex.timer(500), lambda x: reactivex.timer(200)), reactivex.return_value(42) ) Args: first_timeout -- [Optional] Observable sequence that represents the timeout for the first element. If not provided, this defaults to reactivex.never(). timeout_duration_mapper -- [Optional] Selector to retrieve an observable sequence that represents the timeout between the current element and the next element. other -- [Optional] Sequence to return in case of a timeout. If not provided, this is set to reactivex.throw(). Returns: The source sequence switching to the other sequence in case of a timeout. �Timeout)�sourcer c s4 dt jt tt j t jd���� �fdd� }t|�S )N)�observer� schedulerr c s� t � �t � �t� }|�_d�dg� tt d d�� �� ���fdd� ���� � �fdd��td d����� fd d � }td d ���fd d � }d d���fdd� }� j|||�d�|_t���S )NFr )�timeoutr c s� �d ���fdd��t � � � �_td d�� �����fdd� }td d���fdd � }d d �����fd d � }| j|||�d �� _d S )Nr c s � d �kS )Nr � r )�_id�my_idr �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeoutwithmapper.py� timer_winsA s zktimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.set_timer.<locals>.timer_wins��xr c s" �� r�j ��d��_� �� d S )N�r )� subscribe� disposableZdispose)r )�dr �other_r � subscriptionr r r �on_nextG s �zhtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.set_timer.<locals>.on_next)�er c s �� r� � | � d S �N��on_error)r# )r r r r r& O s zitimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.set_timer.<locals>.on_error�r c s �� r�� � ��_d S r$ )r r r )r r r! r r r � on_completedS s zmtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.set_timer.<locals>.on_completedr )r r r � Exceptionr )r r" r& r( )r r r r r! �timer)r r r r � set_timer> s �zWtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.set_timerc s � } | r� d d7 < | S )Nr � r )�res)r �switchedr r � observer_wins] s z[timeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.observer_winsr c sl �� rh� � | � d }z�r"�| �nt�� }W n2 tk r^ } z� �|� W Y �d S d }~X Y nX �|� d S r$ )r" � reactivex�neverr) r& )r r r# )r r/ r+ r r r r" d s � � zUtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.on_next)�errorr c s �� r� � | � d S r$ r% )r2 �r r/ r r r& t s zVtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.on_errorr' c s �� r� � � d S r$ )r( r r3 r r r( x s zZtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe.<locals>.on_completedr ) r r r r r r r) r r )r r �originalr" r& r( )�first_timeout_r r r )r r r/ r r+ r! r. r* r r 1 s& " �zDtimeout_with_mapper_.<locals>.timeout_with_mapper.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r �r5 r r )r r �timeout_with_mapper0 s ��Pz1timeout_with_mapper_.<locals>.timeout_with_mapper)r0 r1 �throwr) r r )r r r r7 r r6 r �timeout_with_mapper_ s Sr9 )NNN)�typingr r r r r0 r r Zreactivex.disposabler r r r r9 �__all__r r r r �<module> s � � x
💾 Save Changes
❌ Cancel