🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:39:18 | 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: _singleordefault.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 eeee 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 sJ t t���d�td�� ��fdd� }�� ��fdd�}�j|� j||d�S )NF��xc s �r� � td�� n| �d�d S )Nz'Sequence contains more than one elementT)�on_error� Exceptionr �r � seen_value�value� �U/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_singleordefault.py�on_next s �z]single_or_default_async_.<locals>.single_or_default_async.<locals>.subscribe.<locals>.on_nextc s, �s� s�� t� � n���� ��� d S )N)r r r � on_completedr )r r r r r r r ! s zbsingle_or_default_async_.<locals>.single_or_default_async.<locals>.subscribe.<locals>.on_completed)r )r r � subscriber )r r r r )r r r r r r s �zLsingle_or_default_async_.<locals>.single_or_default_async.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r �r r )r r �single_or_default_async s �� z9single_or_default_async_.<locals>.single_or_default_async)r r )r r r r r r �single_or_default_async_ s r! )� predicater r c C s* | r t t�| �t�d|��S td|�S dS )a� Returns the only element of an observable sequence that matches the predicate, or a default value if no such element exists this method reports an exception if there is more than one element in the observable sequence. Examples: >>> res = single_or_default() >>> res = single_or_default(lambda x: x == 42) >>> res = single_or_default(lambda x: x == 42, 0) >>> res = single_or_default(None, 0) Args: predicate -- [Optional] A predicate function to evaluate for elements in the source sequence. default_value -- [Optional] The default value if the index is outside the bounds of the source sequence. Returns: An observable Sequence containing the single element in the observable sequence that satisfies the condition in the predicate, or a default value if no such element exists. NT)r �ops�filterZsingle_or_defaultr! )r" r r r r �single_or_default_1 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