U
vi @ sb d dl mZmZmZ d dlmZmZ edZdee eee geee f dddZdgZ dS ) )CallableOptionalTypeVar)
Observableabc_TN)
default_valuereturnc s$ t t t tt d fdd }|S )N)sourcer c s4 dt jtt tt j t jd fdd
}t|S )a Returns the elements of the specified sequence or the
specified value in a singleton sequence if the sequence is
empty.
Examples:
>>> obs = default_if_empty(source)
Args:
source: Source observable.
Returns:
An observable sequence that contains the specified default
value if the source is empty otherwise, the elements of the
source.
N)observer schedulerr c s> dg t d fdd } fdd}j|j||dS )NFxc s d d< | d S )NTr )on_nextr
foundr T/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_defaultifempty.pyr " s zOdefault_if_empty_..default_if_empty..subscribe..on_nextc s d s d S )Nr )r on_completedr )r r r r r r & s
zTdefault_if_empty_..default_if_empty..subscribe..on_completed)r )r subscribeZon_error)r r r r )r r
r r r s z>default_if_empty_..default_if_empty..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r
r r )r
r default_if_empty s z+default_if_empty_..default_if_empty)r r r )r r r r r default_if_empty_ s &r )N)
typingr r r Z reactivexr r r r __all__r r r r s ,