U
vi @ sb d dl mZmZmZ d dlmZmZ d dlmZ edZ eee gee f dddZ
dgZ dS ) )CallableOptionalTypeVar)
Observableabc)noop_T)returnc C s t t t t ddd} | S )zIgnores all elements in an observable sequence leaving only the
termination messages.
Returns:
An empty observable {Observable} sequence that signals
termination, successful or exceptional, of the source sequence.
)sourcer c s. dt jt tt j t jd fdd
}t|S )N)observer schedulerr c s j t| j| j|dS )N)r ) subscriber Zon_errorZ on_completed)r r r
T/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_ignoreelements.pyr
s z.ignore_elements..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r
r
r r r ignore_elements s z)ignore_elements_..ignore_elements)r r )r r r r ignore_elements_ s r N) typingr r r Z reactivexr r Zreactivex.internalr r r __all__r r r r s