_view.setStatusMessageText("Проверка наличия подключения");
Observable.just(appId)
                .flatMap(app -> {
                    if (!NetworkHelper.hasConnection(ApplicationCore.getAppContext()))
                        throw new RuntimeException(ApplicationCore.getAppContext().getString(R.string.error_no_connections));
 
                    if (!NetworkHelper.isHostAvailable(BuildConfig.apiServerIP, BuildConfig.apiServerPort, BuildConfig.TIMEOUT))
                        throw new RuntimeException(ApplicationCore.getAppContext().getString(R.string.error_service_not_available));
 
                    return Observable.just(app);
                })
/* 
как-то так: _view.setStatusMessageText("Получаем актуальную версию");   */
                .flatMap(app -> getApplicationVersions(appId))
/* _view.setStatusMessageText("Получаем список модулей");   */
                .flatMap(app -> getApplicationModules(appId))
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(apps -> {
                           /* any action */
                        },
                        throwable -> {
                            _view.showError(ExceptionHelper.tryParseException(throwable, TAG, 4));
                            _view.hideLoading();
                        });

.observeOn(AndroidSchedulers.mainThread())
                .doOnNext(app -> _view.setStatusMessageText("Получаем список модулей"))
                .observeOn(Schedulers.io())
                .flatMap(app -> getApplicationModules(appId))