U
vi @ s d dl mZmZmZmZ d dlmZmZ d dlmZ d dlm Z d dl
m Z edZ dee e
ee eee d d
d Zdee ee je eee gee f d d
dZdd gZdS ) )AnyCallableOptionalTypeVar)
Observableabc) operators)typing) SequenceContainsNoElementsError_TFN)source has_default
default_valuereturnc s2 dt jtt tt j d fdd
}t|S )N)observer schedulerc sH gdgt d dfdd } fdd}j| j||dS )NF)xr c s | d< d d< d S )Nr T )r )
seen_valuevaluer S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_lastordefault.pyon_next s z9last_or_default_async..subscribe..on_nextc s4 d s s t nd d S )Nr )on_errorr
r on_completedr )r
r r r r r r s z>last_or_default_async..subscribe..on_completed)r )r subscriber )r r r r r r
r )r r r r r s z(last_or_default_async..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 | tt 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)pipeopsfilterlast_or_defaultr )r r r r r r! , s z(last_or_default..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 s*