🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:36:25 | PHP 8.2.32
📂
/ (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: _firstordefault.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZmZ d dlm Z d dl m Z d dl mZ ed�Zdeee eee gee f d �d d �Zdeee ee eee gee f d �d d�Zdd gZdS )� )�Callable�Optional�TypeVar�cast)� Observable�abc�compose)� operators)� SequenceContainsNoElementsError)� Predicate�_TFN)� has_default� default_value�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c s. dt jt tt j d���� fdd� }t|�S )N)�observer� schedulerc s6 t d�� fdd� }��� fdd�}�j|� j||d�S )N��xc s � � | � � �� d S �N)�on_next� on_completedr �r � �T/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_firstordefault.pyr s z[first_or_default_async_.<locals>.first_or_default_async.<locals>.subscribe.<locals>.on_nextc s. �s�� t� � n��tt� �� ��� d S r )�on_errorr r r r r r )r r r r r r s z`first_or_default_async_.<locals>.first_or_default_async.<locals>.subscribe.<locals>.on_completed)r )r � subscriber )r r r r )r r r r r r s �zJfirst_or_default_async_.<locals>.first_or_default_async.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r �r r )r r �first_or_default_async s ��z7first_or_default_async_.<locals>.first_or_default_async)r r )r r r r r r �first_or_default_async_ s r )� predicater r c C s& | r t t�| �t�d|��S td|�S )a� Returns the first element of an observable sequence that satisfies the condition in the predicate, or a default value if no such element exists. Examples: >>> res = source.first_or_default() >>> res = source.first_or_default(lambda x: x > 3) >>> res = source.first_or_default(lambda x: x > 3, 0) >>> res = source.first_or_default(None, 0) Args: source -- Observable sequence. predicate -- [optional] A predicate function to evaluate for elements in the source sequence. default_value -- [Optional] The default value if no such element exists. If not specified, defaults to None. Returns: A function that takes an observable source and reutrn an observable sequence containing the first element in the observable sequence that satisfies the condition in the predicate, or a default value if no such element exists. NT)r �ops�filterZfirst_or_defaultr )r r r r r �first_or_default_' s r# )FN)NN)�typingr r r r Z reactivexr r r r r! Z reactivex.internal.exceptionsr Zreactivex.typingr r �boolr r# �__all__r r r r �<module> s( � � � �
💾 Save Changes
❌ Cancel