🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:25:29 | 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: _takewhile.cpython-38.pyc
Read Only
U v�i � @ s� d dl mZmZmZmZ d dlmZmZ d dlm Z m Z ed�Z d e e e eee gee f d�dd�Z d e e e eee gee f d�d d �Zdd gZd S )� )�Any�Callable�Optional�TypeVar)� Observable�abc)� Predicate�PredicateIndexed�_TF)� predicate� inclusive�returnc s" t t t t d�� �fdd� }|S )N��sourcer c s2 dt jt tt j t jd���� fdd� }t|�S )a� Returns elements from an observable sequence as long as a specified condition is true. Example: >>> take_while(source) Args: source: The source observable to take from. Returns: An observable sequence that contains the elements from the input sequence that occur before the element at which the test no longer passes. N��observer� schedulerr c s4 d�t d��� ���fdd� }�j|� j� j|d�S )NT)�valuec s� �j �b �sW 5 Q R � d S z �| ��W n< tk rb } z ��|� W Y �W 5 Q R � d S d }~X Y nX W 5 Q R X �r~��| � n� r���| � ��� d S )N��lock� Exception�on_error�on_next� on_completed�r Zexn)r r r �runningr � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takewhile.pyr " s , zCtake_while_.<locals>.take_while.<locals>.subscribe.<locals>.on_next�r )r � subscriber r �r r r �r r r )r r r r s �z2take_while_.<locals>.take_while.<locals>.subscribe)N�r Z ObserverBaser r Z SchedulerBaseZDisposableBaser �r r �r r �r r � take_while s �� z take_while_.<locals>.take_while�r r )r r r& r r$ r � take_while_ s 0r( c s" t t t t d�� �fdd� }|S )Nr c s2 dt jt tt j t jd���� fdd� }t|�S )a� Returns elements from an observable sequence as long as a specified condition is true. The element's index is used in the logic of the predicate function. Example: >>> take_while(source) Args: source: Source observable to take from. Returns: An observable sequence that contains the elements from the input sequence that occur before the element at which the test no longer passes. Nr c s< d�d� t d d�� �����fdd� }�j|�j�j|d�S )NTr )r r c s� �j �l �sW 5 Q R � d S z�| � ��W n< tk rd } z ��|� W Y �W 5 Q R � d S d }~X Y n X � d7 � W 5 Q R X �r���| � n�r���| � ��� d S )N� r r )�ir r r r r r r r Z s " zStake_while_indexed_.<locals>.take_while_indexed.<locals>.subscribe.<locals>.on_nextr )r r r r r r! )r* r r r r S s �zBtake_while_indexed_.<locals>.take_while_indexed.<locals>.subscribe)Nr" r# r$ r% r �take_while_indexedB s ��!z/take_while_indexed_.<locals>.take_while_indexedr' )r r r+ r r$ r �take_while_indexed_? s 4r, N)F)F)�typingr r r r Z reactivexr r Zreactivex.typingr r r �boolr( r, �__all__r r r r �<module> s � � 7 � � :
💾 Save Changes
❌ Cancel