🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:24:24 | 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: _skipwhile.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZmZ d dlm Z d dlm Z ed�Z e j e eee gee f d�dd�Z e je eee gee f d�d d �Zdd gZd S ) � )�Callable�Optional�Tuple�TypeVar)� Observable�abc�compose)� operators)�typing�_T)� predicate�returnc s t t t t d�� fdd� }|S )N)�sourcer c s, dt jt tt j d��� fdd� }t|�S )aN Bypasses elements in an observable sequence as long as a specified condition is true and then returns the remaining elements. The element's index is used in the logic of the predicate function. Example: >>> skip_while(source) Args: source: The source observable to skip elements from. Returns: An observable sequence that contains the elements from the input sequence starting at the first element in the linear series that does not pass the test specified by predicate. N)�observer� schedulerc s0 d�t d�� ��fdd� }�j|� j� j|d�S )NF)�valuec sX �sFz�| � �W n2 t k rD } z� �|� W Y �d S d }~X Y nX �rT� �| � d S �N)� Exception�on_error�on_next)r Zexn)r r �running� �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipwhile.pyr % s zCskip_while_.<locals>.skip_while.<locals>.subscribe.<locals>.on_next)r )r � subscriber Z on_completed)r r r )r r )r r r r s �z2skip_while_.<locals>.skip_while.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r �r )r r � skip_while s ��z skip_while_.<locals>.skip_while)r r )r r r r r � skip_while_ s +r c sl t ttt tf d�dd�}tt tf td�� fdd� }tt tf t d�dd�}tt�|�t�|�t�|��S ) N)�x�ir c S s | |fS r r )r r r r r �indexer> s z$skip_while_indexed_.<locals>.indexer)r r c s � | � S r r �r r r r �skipperA s z$skip_while_indexed_.<locals>.skipperc S s | d S )Nr r r r r r �mapperD s z#skip_while_indexed_.<locals>.mapper) r �intr �boolr �opsZ map_indexedr �map)r r r! r" r r r �skip_while_indexed_; s �r' N)r r r r r Z reactivexr r r r r% r Z Predicater ZPredicateIndexedr' �__all__r r r r �<module> s � 2�
💾 Save Changes
❌ Cancel