Android, RxJava, AsyncTask и поворот экрана — как собрать все вместе?

Question

[Александр]

Здравствуйте!

Есть главное активити с загрузкой фрагмента. Фрагмент самодостаточен и в активити не передает данные. Во фрагменте реализован простейший AsyncTask с перебором массива и вывода прогресса текущей операции в окно диалога (в TextView выводим элемент массива, в ProgressBar - его номер).

Возможно ли в принципе, без танцев с бубном и кучей кода, перевести код AsyncTask на RxJava да так, чтобы корректно обрабатывался и поворот экрана устройства?
Где можно найти рабочий пример, как это можно организовать?

Читал это
stackoverflow.com/questions/33980194/asynctask-in-...
и это ru.stackoverflow.com/questions/486838/alertdialog-...
и тут ru.stackoverflow.com/questions/470393/asynctask-%D...

Близко, но не то.

Answer 1

[Денис Загаевский]

В RxJava есть механизмы для этого, например cache();

Observable<Photo> request = service.getUserPhoto(id).cache();
Subscription sub = request.subscribe(photo -> handleUserPhoto(photo));

// перед тем, как активити пересоздаётся
sub.unsubscribe();

// когда она пересоздалась
request.subscribe(photo -> handleUserPhoto(photo));

При этом нужно сохранять где-то вне активити request, это должен быть тот же объект. Это не серебряная пуля, в разных случаях надо поступать по-разному. Для того, чтобы гарантированно отписываться при пересоздании проще использовать CompositeSubscribtion.
Подробнее здесь почитать можно: blog.danlew.net/2014/10/08/grokking-rxjava-part-4
И, вроде бы, на хабре был перевод.

Comments

[Александр]

Простой рабочий пример не встречался?

[Денис Загаевский]

cry_san: у вас уже есть Observable, который делает то же самое, что ваш асинктаск? Если нет, начните с этого. Если хотите в Rx, придётся поднапрячься.

[Александр]

По тем примерам - Observable не проблема. Проблема в отображении прогресса и в повороте устройства.

[Денис Загаевский]

cry_san: Изучайте Rx, там всё это не проблема. По ссылке хоть сходили? Что вам мешает взять и попробовать?

[Александр]

Сходил. Вопрос про поворот решен. А про отображение? Простой TextView.setText("лала") в Observable не работает.

[Денис Загаевский]

cry_san: почему не работает? Нужно делать такие вещи только в подписчике, используя .observeOn(AndroidSchedulers.mainThread()). А изменение глобального состояния во время выполнения цепочки преобразований противоречит логике Rx.

[Александр]

Наткнулся на это: https://github.com/rovkinmax/RxRetainFragment
Проблема решена.
Всех благодарю!

Answer 2

[Tiberal]

Можно все обернуть в лоадер, он привязан к жизненному циклу
или вот https://github.com/trello/RxLifecycle

Comments

[Александр]

лоадер можно, но вопрос был не в том;
RxLifecycle всего лишь позволяет автоматически завершать.

Answer 3

[finCoder]

Также можно сохранять в Retaince Fragment, который будет выглядеть примерно так

public class RetainFragment<T> extends Fragment {

    @NonNull
    public static <T> RetainFragment<T> newInstance() {
        final RetainFragment<T> retainFragment = new RetainFragment<>();
        retainFragment.setRetainInstance(true);
        return retainFragment;
    }

    private T object;

    @NonNull
    public T getObject() {
        return object;
    }

    public void setObject(@NonNull T object) {
        this.object = object;
    }
}

Здесь неплохой пример

Comments

[Александр]

Благодарю!