🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:25:52 | 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: _skipuntil.cpython-38.pyc
Read Only
U v�iU � @ s� d dl mZ d dlmZmZmZmZmZ d dlm Z m Z m Z d dl m Z mZ ed�Zee e df ee e ge e f d�dd �Zd gZd S ) � )�Future)�Any�Callable�Optional�TypeVar�Union)� Observable�abc� from_future)�CompositeDisposable�SingleAssignmentDisposable�_Tz Future[Any])�other�returnc s8 t | t�rt| �� n| � tt tt d�� fdd� }|S )a� Returns the values from the source observable sequence only after the other observable sequence produces a value. Args: other: The observable sequence that triggers propagation of elements of the source sequence. Returns: An observable sequence containing the elements of the source sequence starting from the point the other sequence triggered propagation. )�sourcer c s, dt jt tt j d��� fdd� }t|�S )N)�observer� schedulerc s� dg� t d d�� �fdd� }d d�� �fdd� }�j|�j||d�}t|�}t� �|��� td d �� �fd d � }�fd d �}�j|�j||d��_|S )NF)�leftr c s � d r�� | � d S �Nr )�on_next)r ��is_openr � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipuntil.pyr & s zCskip_until_.<locals>.skip_until.<locals>.subscribe.<locals>.on_next)r c s � d r�� � d S r )� on_completedr r r r r * s zHskip_until_.<locals>.skip_until.<locals>.subscribe.<locals>.on_completed)r )�xr c s d� d< �� � d S )NTr �Zdispose)r )r �right_subscriptionr r �on_next26 s zDskip_until_.<locals>.skip_until.<locals>.subscribe.<locals>.on_next2c s � � � d S )Nr r )r r r � on_completed2: s zIskip_until_.<locals>.skip_until.<locals>.subscribe.<locals>.on_completed2)r � subscribeZon_errorr r �addr Z disposable)r r r r �subsZ subscriptionsr r )�obsr )r r r r r s* � �z2skip_until_.<locals>.skip_until.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r �r# )r r � skip_until s ��#z skip_until_.<locals>.skip_until)� isinstancer r r r )r r% r r$ r � skip_until_ s &r' N)�asyncior �typingr r r r r Z reactivexr r r Zreactivex.disposabler r r r' �__all__r r r r �<module> s � >
💾 Save Changes
❌ Cancel