UserPresenter.java

public void getUser(String userId) {
  getView().showLoading(“fetching user…”);
  
  Subscription sub = userRepository.getUser(userId) 
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidScheduler.mainThread())
    .subscribe(user -> {
        getView().stopLoading();
        getView().render(user);
    },e->{
        getView.stopLoading();
        getView().renderError(e);
    })
    
  compositeSubscription.add(subscription);
}