RxJava: последовательность запросов с изменением статусов на UI

@RxSam · Регистрация: 14.05.2018

Author24 — интернет-сервис помощи студентам

Всем привет =)

При запуске приложения, открывается активити, состоящая из progressbar для отображения статуса загрузки и textview, в котором, в котором отображается конкретный шаг, который выполняется в текущий момент.

Цель данного активити, получать некоторые данные с сервера (актуальность версии, обновленные настройки, информация о пользователе и т.п.). Все работает в связке retrofit + rxjava.

По факту, для каждого запроса есть свой Observable. Все они должны выполняться по очереди (через flatMap или zip).

Проблема в том, что я не могу обновлять статусы отработки методов в textview, после каждого выполненного\невыполненного запроса, так как не имею доступа к mainThread.

Java

_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();
                        });

Подскажите, как обновлять UI между выполненными запросами (Observable)?

Добавлено через 47 минут
Извиняюсь, тупанул...

нужно переключаться между потоками observeOn:

Java

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

	14.05.2018, 12:38

Опции темы