🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:16:08 | 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: _elementatordefault.cpython-38.pyc
Read Only
U v�i � @ sr d dl mZmZmZmZ d dlmZmZ d dlm Z ed�Z d e e ee eee gee f d�dd �Z d gZdS ) � )�Callable�Optional�TypeVar�cast)� Observable�abc)�ArgumentOutOfRangeException�_TFN)�index� has_default� default_value�returnc s2 �dk rt � �tt tt d�� ��fdd� }|S )Nr )�sourcer c s4 dt jt tt j t jd����� fdd� }t|�S )N)�observer� schedulerr c s@ �� t d d�� ��fdd� }���fdd�}�j|�j||d�S )N)�xr c sB d}�j � � r� d8 � nd}W 5 Q R X |r>��| � ��� d S )NF� T)�lock�on_next� on_completed)r �found)�index_r r � �X/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_elementatordefault.pyr s zYelement_at_or_default_.<locals>.element_at_or_default.<locals>.subscribe.<locals>.on_nextc s. �s�� t� � n��tt� �� ��� d S )N)�on_errorr r r r r r )r r r r r r # s z^element_at_or_default_.<locals>.element_at_or_default.<locals>.subscribe.<locals>.on_completed)r )r � subscriber )r r r r )r r r r )r r r r s �zHelement_at_or_default_.<locals>.element_at_or_default.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r �r r r )r r �element_at_or_default s �� z5element_at_or_default_.<locals>.element_at_or_default)r r r )r r r r r r r �element_at_or_default_ s !r )FN)�typingr r r r Z reactivexr r Z reactivex.internal.exceptionsr r �int�boolr �__all__r r r r �<module> s � � *
💾 Save Changes
❌ Cancel