U
vi @ s d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
edZ d e e e eee gee f dddZ
d
e
e e eee gee f dd d
Zdd
gZd S ) )AnyCallableOptionalTypeVar)
Observableabc) PredicatePredicateIndexed_TF) predicate inclusivereturnc s" t t t t d fdd }|S )Nsourcer
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.
Nobserver schedulerr
c s4 dt d fdd }j| j j|dS )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 )Nlock Exceptionon_erroron_next on_completedr Zexn)r r r runningr O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takewhile.pyr " s
,
zCtake_while_..take_while..subscribe..on_nextr )r
subscriber r r r r r r r )r r r r s z2take_while_..take_while..subscribe)Nr Z ObserverBaser
r Z
SchedulerBaseZDisposableBaser r r r r r r
take_while s z take_while_..take_whiler 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< dd t d d fdd }j|jj|dS )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| nr| d S )N r r )ir r r r r r r r Z s
"
zStake_while_indexed_..take_while_indexed..subscribe..on_nextr )r r r r r r! )r* r r r r S s zBtake_while_indexed_..take_while_indexed..subscribe)Nr" r# r$ r% r take_while_indexedB s !z/take_while_indexed_..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 s 7 :