

@extensionmethod(Observable)
def ignore_elements(self):
    'Ignores all elements in an observable sequence leaving only the\n    termination messages.\n\n    Returns an empty observable {Observable} sequence that signals\n    termination, successful or exceptional, of the source sequence.\n    '
    source = self

    def subscribe(observer):
        return source.subscribe(noop, observer.on_error, observer.on_completed)
    return AnonymousObservable(subscribe)

dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/ignoreelements.py ignore_elements/original