Implement Rx Subscribe with error handling