🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:27:27 | 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: _takeuntil.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZ d dlmZm Z m Z d dl m Z d dl mZ ed�Zeee df eee gee f d�d d �Zd gZd S ) � )�Future)�Callable�Optional�TypeVar�Union)� Observable�abc� from_future)�CompositeDisposable)�noop�_Tz Future[_T])�other�returnc s8 t | t�rt| �� n| � tt tt d�� fdd� }|S )N)�sourcer c s0 dt jt tt j t jd��� fdd� }t|�S )a� Returns the values from the source observable sequence until the other observable sequence produces a value. Args: source: The source observable sequence. Returns: An observable sequence containing the elements of the source sequence up to the point the other sequence interrupted further propagation. N)�observer� schedulerr c s8 t d d�� fdd� }t�j� |d��j|� jt|d��S )N)�_r c s � � � d S )N)� on_completed)r �r � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takeuntil.pyr $ s zHtake_until_.<locals>.take_until.<locals>.subscribe.<locals>.on_completed)r )r r � subscribeZon_errorr )r r r )�obsr r r r s ��z2take_until_.<locals>.take_until.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r �r )r r � take_until s ��z take_until_.<locals>.take_until)� isinstancer r r r )r r r r r � take_until_ s r N)�asyncior �typingr r r r Z reactivexr r r Zreactivex.disposabler Zreactivex.internalr r r �__all__r r r r �<module> s � (
💾 Save Changes
❌ Cancel