🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:56:44 | 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: _lastordefault.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZ d dlmZ d dlm Z d dl m Z ed�Z dee e ee eee d �d d �Zdee ee je eee gee f d �d d�Zdd gZdS )� )�Any�Callable�Optional�TypeVar)� Observable�abc)� operators)�typing)� SequenceContainsNoElementsError�_TFN)�source� has_default� default_value�returnc s2 dt jtt tt j d�� ��fdd� }t|�S )N)�observer� schedulerc sH �g�dg�t d d���fdd� }�� ��fdd�}�j|� j||d�S )NF)�xr c s | �d< d� d< d S )Nr T� )r )� seen_value�valuer �S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_lastordefault.py�on_next s z9last_or_default_async.<locals>.subscribe.<locals>.on_nextc s4 �d s� s�� t� � n���d � ��� d S )Nr )�on_errorr r � on_completedr )r r r r r r r s z>last_or_default_async.<locals>.subscribe.<locals>.on_completed)r )r � subscriber )r r r r �r r r )r r r r r s �z(last_or_default_async.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r r r r r r �last_or_default_async s � �r )r � predicater c s" t t t t d�� �fdd� }|S )N)r r c s( �r | � t���t�� ��S t| d� �S )a2 Return last or default element. Examples: >>> res = _last_or_default(source) Args: source: Observable sequence to get the last item from. Returns: Observable sequence containing the last element in the observable sequence. T)�pipe�ops�filter�last_or_defaultr )r �r r r r r! , s �z(last_or_default.<locals>.last_or_default)r r )r r r! r r" r r! ) s r! )FN)NN)r r r r r Z reactivexr r r r Z reactivex.internal.exceptionsr r �boolr Z Predicater! �__all__r r r r �<module> s* � � � �
💾 Save Changes
❌ Cancel