def on_completed(self):

        if not self.is_stopped:
            AbstractObserver.dispose(self)
            self._completed()
Notifies the observer of the end of the sequence.
dataset/ETHPy150Open ReactiveX/RxPY/rx/abstractobserver.py/AbstractObserver.on_completed