# may exceed call stack :(

@extensionmethod(rx.Observable, instancemethod=True)
def on_error_resume(self, handler=None):
    def _inner(exc):
        if callable(handler):
            handler(exc)
        return self.catch_exception(_inner)
    return self.catch_exception(_inner)