🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 05:59:22 | PHP 8.2.33
📂
/ (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: _exclusive.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZ d dlZd dlmZm Z d dl m Z m Z ed�Z eeee gee f d�dd �Zd gZdS ) � )�Future)�Callable�Optional�TypeVar�UnionN)� Observable�abc)�CompositeDisposable�SingleAssignmentDisposable�_T��returnc C s t t t t t d�dd�} | S )a! Performs a exclusive waiting for the first to finish before subscribing to another observable. Observables that come in between subscriptions will be dropped on the floor. Returns: An exclusive observable with only the results that happen when subscribed. )�sourcer c s. dt jt tt j t jd�� fdd� }t|�S )N)�observer� schedulerr c s| dg�dg�t � }t� � � �|� ttt df d d�� ����fdd� }d d�� ���fdd� }�j|�j|�d �|_� S ) NFz Future[_T])� inner_sourcer c sh �d sdd�d< t | t�r$t�| �n| } t� � ��� � ��� ��fdd�}| j�j�j|�d�� _ d S )Nr Tc s2 � � �� d�d< �d r.t� �dkr.��� d S )NFr � )�remove�len� on_completed� )�g� has_current�inner_subscription� is_stoppedr r �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_exclusive.py�on_completed_inner. s z]exclusive_.<locals>.exclusive.<locals>.subscribe.<locals>.on_next.<locals>.on_completed_inner�r ) � isinstancer � reactivexZ from_futurer �add� subscribe�on_next�on_error� disposable)r r �r r r r r )r r r" ! s � � �zAexclusive_.<locals>.exclusive.<locals>.subscribe.<locals>.on_nextr c s( d�d< �d s$t � �dkr$��� d S )NTr r )r r r )r r r r r r r ; s zFexclusive_.<locals>.exclusive.<locals>.subscribe.<locals>.on_completedr ) r r r r r r r! r# r$ )r r �mr" r �r r% r r! s ( �z0exclusive_.<locals>.exclusive.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r! r r' r � exclusive s ��/z exclusive_.<locals>.exclusive)r r )r( r r r � exclusive_ s 2r) )�asyncior �typingr r r r r r r Zreactivex.disposabler r r r) �__all__r r r r �<module> s $?
💾 Save Changes
❌ Cancel