Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- repositoryErrorNotSended = true;
- activityRepository.getAllActivities(u)
- .doOnError(e -> repositoryError(e))
- .onErrorResumeNext(Observable.empty())
- .subscribe(r -> {
- if (fromRemoteStorage)
- view().onDataUpdate(r);
- else
- view().onDataLoad(r);
- });
- activityRepository.getCloudBalance(u)
- .doOnError(e -> repositoryError(e))
- .onErrorResumeNext(Observable.empty())
- .subscribe(r -> {
- u.setBalance(r);
- view().onUserInfoLoad(u);
- });
- private boolean repositoryErrorNotSended = true;
- private void repositoryError(Throwable throwable) {
- if (throwable != null) {
- view().hideProgress();
- if (repositoryErrorNotSended) {
- repositoryErrorNotSended = false;
- view().showNetworkExceptionError();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement