RxjavaExample.java

               showProgress("Loading..");

                ApiClient.getInstance().login(email,pass) ///   api call
                        .retryWhen(new RetryWithDelay(5,1000))
                        .doAfterNext(userResponse -> {
                            if(userResponse.isStatus()){
                                if(userResponse.getBody() != null){
                                    User user = userResponse.getBody();
                                    setUser(user);

                                }

                            }
                        })
                        .flatMap(userResponse -> {

                           return AppDatabase.getInstance(LoginActivity.this)
                                    .bootMeDoa().getAll().defaultIfEmpty(new ArrayList<>()).toFlowable()  ///   database call
                                    .flatMap(list -> {
                                        if(!list.isEmpty()) {

                                            BootMe bootMe = new BootMe();
                                            bootMe.message_timeout = list.get(0).message_timeout;
                                            bootMe.profession = list.get(0).profession;
                                            setBootMe(bootMe);

                                            return Flowable.empty();
                                        }else {

                                            return ApiClient.getInstance().boot_me()               ///   api call
                                                    .retryWhen(new RetryWithDelay(5,1000))
                                                    .doAfterNext(bootMeResponse -> {
                                                        if(bootMeResponse != null && bootMeResponse.getBody() != null) {
                                                            setBootMe(bootMeResponse.getBody());
                                                            BootMeItem bootMeItem = new BootMeItem();
                                                            bootMeItem.profession = bootMeResponse.getBody().profession;
                                                            bootMeItem.message_timeout = bootMeResponse.getBody().message_timeout;

                                                            AppDatabase.getInstance(LoginActivity.this)
                                                                    .bootMeDoa().insertItem(bootMeItem);
                                                        }

                                                    });

                                        }
                                    });

                        })
                        .compose(RxUtil.applySchedulers())
                        .compose(bindUntilEvent(ActivityEvent.STOP))
                        .subscribe(userResponse -> {

                            hideProgress();
                            launchHomeActivity();

                        },t->showError(t.getMessage()));