U
vi/ @ s d dl Z d dlmZ d dlmZmZmZ d dlZd dlmZ d dl m
Z
d dl m Z edZ
e ee
eee
gee
f dd d
Zd
gZdS ) N)Future)CallableTypeVarUnion)
Observable)infinite) Predicate_T) conditionreturnc s( t tt df tt d fdd }|S )Nz
Future[_T])sourcer c s@ t | trt| n| t fddt D }t|S )aI Repeats source as long as condition holds emulating a while
loop.
Args:
source: The observable sequence that will be run if the
condition function returns true.
Returns:
An observable sequence which is repeated as long as the
condition holds.
c 3 s | ]
} V qd S )N ).0_Zobsr
M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_whiledo.py s z.while_do_..while_do..)
isinstancer reactivexZ from_future itertools takewhiler Zconcat_with_iterable)r itr
r r while_do s
zwhile_do_..while_do)r r r )r
r r
r r while_do_
s $r )r asyncior typingr r r r r Zreactivex.internal.utilsr Zreactivex.typingr r r __all__r
r
r
r s