🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:31:30 | 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: _switchlatest.cpython-38.pyc
Read Only
U v�i\ � @ s� d dl mZ d dlmZmZmZmZmZ d dlm Z m Z m Z d dl m Z mZmZ ed�Zee ee e df ge e f d�dd �Zd gZd S ) � )�Future)�Any�Callable�Optional�TypeVar�Union)� Observable�abc� from_future)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable�_T� Future[_T]��returnc C s( t tt t df t t d�dd�} | S )Nr )�sourcer c s. dt jt tt j t jd�� fdd� }t|�S )a� Partially applied switch_latest operator. Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence. Returns: An observable sequence that at any point in time produces the elements of the most recent inner observable sequence that has been received. N)�observer� schedulerr c sx t � �dg� dg�dg�ttt df d d�� ������fdd� }d d�� ��fdd � }�j|�j|�d �}t|��S ) NFr r )� inner_sourcer c s� t � }�j� �d d7 < �d � W 5 Q R X d�d< |�_t| t�rRt| �}n| }td d�� ��fdd� }td d�� ��fdd � }d d �� ����fd d � }|j|||�d �|_d S )Nr � T)�xr c s �d � kr�� | � d S �Nr )�on_next)r ��_id�latestr � �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_switchlatest.pyr 9 s zZswitch_latest_.<locals>.switch_latest.<locals>.subscribe.<locals>.on_next.<locals>.on_next)�er c s �d � kr�� | � d S r )�on_error)r r r r r = s z[switch_latest_.<locals>.switch_latest.<locals>.subscribe.<locals>.on_next.<locals>.on_errorr c s( �d � kr$d�d< �d r$�� � d S )Nr F�� on_completedr )r � has_latest� is_stoppedr r r r r" A s z_switch_latest_.<locals>.switch_latest.<locals>.subscribe.<locals>.on_next.<locals>.on_completed�r ) r �lockZ disposable� isinstancer r r � Exception� subscribe)r �dZobsr r r" )r# �inner_subscriptionr$ r r r r )r r r ) s$ �zIswitch_latest_.<locals>.switch_latest.<locals>.subscribe.<locals>.on_nextr c s d�d< � d s�� � d S )NTr r! r )r# r$ r r r r" K s zNswitch_latest_.<locals>.switch_latest.<locals>.subscribe.<locals>.on_completedr% )r r r r r) r r )r r r r" Z subscription�r )r# r+ r$ r r r r r) s ," �z8switch_latest_.<locals>.switch_latest.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r) r r, r � switch_latest s ��5z%switch_latest_.<locals>.switch_latest)r r r )r- r r r �switch_latest_ s � Fr. N)�asyncior �typingr r r r r Z reactivexr r r Zreactivex.disposabler r r r r. �__all__r r r r �<module> s � L
💾 Save Changes
❌ Cancel