RetrofitSingleSubscriber

RetrofitSingleSubscriber.java

public abstract class RetrofitSingleSubscriber<T> extends SingleSubscriber<T> {

  public abstract void onHttpError(HttpException e);

  public abstract void onNonHttpError(Throwable e);

  @Override public void onError(Throwable error) {
    if (error instanceof HttpException) {
      onHttpError((HttpException) error);
    } else {
      onNonHttpError(error);
    }
  }
}

RetrofitSingleSubscriber.java2

public abstract class RetrofitSingleSubscriber<T> extends SingleSubscriber<T> {

  private final Converter<ResponseBody, ErrorResponse> converter;

  public RetrofitSingleSubscriber(Converter<ResponseBody, ErrorResponse> converter) {
    this.converter = converter;
  }

  public abstract void onHttpError(HttpException e, ErrorResponse response);

  public abstract void onNonHttpError(Throwable e);

  @Override public void onError(Throwable error) {
    if (error instanceof HttpException) {
      final HttpException hex = (HttpException) error;
      onHttpError(hex, getErrorResponse(hex));
    } else {
      onNonHttpError(error);
    }
  }

  private ErrorResponse getErrorResponse(HttpException ex) {
    try {
      return converter.convert(ex.response().errorBody());
    } catch (IOException e) {
      return null;
    }
  }
}

RetrofitSingleSubscriber.java3

public abstract class RetrofitSingleSubscriber<T> extends SingleSubscriber<T> {

  public abstract void onHttpError(HttpException e, ErrorResponse response);

  public abstract void onNonHttpError(Throwable e);

  @Override public void onError(Throwable error) {
    if (error instanceof HttpException) {
      final HttpException hex = (HttpException) error;
      onHttpError(hex, getErrorResponse(hex));
    } else {
      onNonHttpError(error);
    }
  }

  private ErrorResponse getErrorResponse(HttpException ex) {
    try {
      return new Gson().fromJson(ex.response().errorBody().string(), ErrorResponse.class);
    } catch (IOException e) {
      return null;
    }
  }
}