def on_error(self, error):

        if not self.is_stopped:
            AbstractObserver.dispose(self)
            self._error(error)
Notifies the observer that an exception has occurred.
dataset/ETHPy150Open ReactiveX/RxPY/rx/abstractobserver.py/AbstractObserver.on_error