code: private void handleException(Throwable e, Subscriber<? super T> subscriber) {
          debug("onError: ", e.getMessage());
          Exceptions.throwOrReport(e, subscriber);
      }
docs: Notify observer of an error.
  
  @param e
  @param subscriber