U
vi @ s d dl mZmZmZmZ d dlmZmZmZ d dlm Z
d dl m Z d dl
mZ edZdeee eee gee f d d
d Zdeee ee eee gee f d d
dZdd gZdS ) )CallableOptionalTypeVarcast)
Observableabccompose) operators) SequenceContainsNoElementsError) Predicate_TFN) has_default
default_valuereturnc 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||dS )Nxc 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_..first_or_default_async..subscribe..on_nextc s. s t ntt d S r )on_errorr
r r r r r )r r
r r r r s z`first_or_default_async_..first_or_default_async..subscribe..on_completed)r )r subscriber )r r r r )r r
r r r r s zJfirst_or_default_async_..first_or_default_async..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser )r r r r
)r r first_or_default_async s z7first_or_default_async_..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| td|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 opsfilterZfirst_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 s(