🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 01:24:41 | PHP 8.2.33
📂
/ (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: _whiledo.cpython-38.pyc
Read Only
U v�i/ � @ s� d dl Z d dlmZ d dlmZmZmZ d dlZd dlmZ d dl m Z d dl m Z ed�Z e ee eee gee f d�d d �Zd gZdS ) � N)�Future)�Callable�TypeVar�Union)� Observable)�infinite)� Predicate�_T)� condition�returnc s( t tt df tt d�� fdd� }|S )Nz Future[_T])�sourcer c s@ t | t�rt�| �� n| � t��� fdd�t� 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� <genexpr> s z.while_do_.<locals>.while_do.<locals>.<genexpr>)� isinstancer � reactivexZ from_future� itertools� takewhiler Zconcat_with_iterable)r �it�r r r �while_do s zwhile_do_.<locals>.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 �<module> s �
💾 Save Changes
❌ Cancel