U
vi @ s d dl mZmZmZmZ d dlmZmZmZ d dlm Z
d dlm Z edZ e j e eee gee f dddZ
e je eee gee f dd d
Zdd
gZd S ) )CallableOptionalTupleTypeVar)
Observableabccompose) operators)typing_T) predicatereturnc 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 dt d fdd }j| j j|dS )NF)valuec
sX sFz| W n2 t k
rD } z | W Y d S d }~X Y nX rT | d S N) Exceptionon_erroron_next)r Zexn)r r running O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipwhile.pyr % s
zCskip_while_..skip_while..subscribe..on_next)r )r subscriber Z on_completed)r r r )r r )r r r r s
z2skip_while_..skip_while..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser )r r r )r r
skip_while
s z skip_while_..skip_while)r r )r r r r r skip_while_
s +r c sl t ttt tf ddd}tt tf td fdd }tt tf t ddd}tt|t|t|S ) N)xir
c S s | |fS r r )r r r r r indexer> s z$skip_while_indexed_..indexer)r r
c s | S r r r r r r skipperA s z$skip_while_indexed_..skipperc S s | d S )Nr r r r r r mapperD s z#skip_while_indexed_..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 s 2