🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 21:34:27 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: ifthen.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZ d dlZd dlmZmZ ed�Z d eg e f eee df edee df ee d�dd �Z d gZ dS ) � )�Future)�Callable�TypeVar�UnionN)� Observable�abc�_T� Future[_T])� condition� then_source� else_source�returnc sl |p t �� �t�t�r t ���n��t�t�r8t ���n��tjttt df d�� ��fdd� }t � |�S )a� Determines whether an observable collection contains values. Example: 1 - res = reactivex.if_then(condition, obs1) 2 - res = reactivex.if_then(condition, obs1, obs2) Args: condition: The condition which determines if the then_source or else_source will be run. then_source: The observable sequence or Promise that will be run if the condition function returns true. else_source: [Optional] The observable sequence or Promise that will be run if the condition function returns False. If this is not provided, it defaults to reactivex.empty Returns: An observable sequence which is either the then_source or else_source. r )�_r c s � � r �S �S )N� )r �r Z else_source_r r �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/ifthen.py�factory1 s zif_then_.<locals>.factory) � reactivex�empty� isinstancer Z from_futurer Z SchedulerBaser r r Zdefer)r r r r r r r �if_then_ s � �� �&r )N) �asyncior �typingr r r r r r r �boolr �__all__r r r r �<module> s � � -
💾 Save Changes
❌ Cancel