Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Override
- public void initData() {
- addToCompDisp(Single.concat(getProducts(), getEmployers(), getMenu())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .doOnSubscribe(data -> getView().showInitLoading())
- .doOnError(data -> getView().initError())
- .subscribe(data -> {
- },
- throwable -> {
- handleError(throwable, R.string.init_error);
- },
- () -> {
- getView().showMainLayout();
- getView().showMenu(parseMenu());
- })
- );
- }
- private Single<List<Employe>> getEmployers() {
- return RetrofitFactory.getRetrofitService().getEmployers(mDataManager.getLsId(), mDataManager.getBidId())
- .doOnSuccess(list -> mDataManager.getEmployeStorage().setEmployes(list))
- .doOnError(throwable -> getView().showToast(R.string.init_error_get_employers))
- .flatMap(list -> Single.error(new Throwable("Custom error")));
- }
- private Single<List<Main>> getMenu() {
- return RetrofitFactory.getRetrofitService().getMenu(mDataManager.getLsId(), mDataManager.getBidId())
- .doOnSuccess(menu -> mDataManager.setMenu(menu))
- .doOnError(throwable -> getView().showToast(R.string.init_error_get_menu));
- }
- private Single<ResponseBody> getProducts() {
- return RetrofitFactory.getRetrofitService().getProducts(mDataManager.getLsId(), mDataManager.getBidId())
- .doOnSuccess(responseBody -> parseProducts(responseBody.string()))
- .doOnError(throwable -> getView().showToast(R.string.error_get_products));
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement