4

У меня есть AsyncTask, который я хочу переделать в Rx

Вот так выглядит мой AsyncTask

new AsyncTask<Void, Void, Void>()
    {
        ArrayList<CallServiceCode> undoneServiceCodes = new ArrayList<>();
        HashMap<String, ServicePartFormQuestionsManager> undoneForms = new HashMap<>();
        boolean isHasAtLeastOneDoneServiceCode = false;

        @Override
        protected void onPreExecute()
        {
            super.onPreExecute();

            if (iCloseCallListener != null)
            {
                iCloseCallListener.onPreValidation();
            }
        }

        @Override
        protected Void doInBackground(Void... params)
        {
            undoneServiceCodes = getUndoneServiceCodes();
            undoneForms = getUndoneForms();
            isHasAtLeastOneDoneServiceCode = isHasAtLeastOneDoneServiceCode();

            return null;
        }

        @Override
        protected void onPostExecute(Void iVoid)
        {
            super.onPostExecute(iVoid);

            if (iCloseCallListener != null)
            {
                iCloseCallListener.onPostValidation(undoneServiceCodes, undoneForms, isHasAtLeastOneDoneServiceCode);
            }
        }
    }.execute();

Мне не понятно как можно выполнить в бекграунде Rx , можно выполнить сразу 3 разных метода как в примере с AsyncTask когда в бекграунде выполняется 3 метода

  1. undoneServiceCodes = getUndoneServiceCodes();
  2. undoneForms = getUndoneForms();
  3. isHasAtLeastOneDoneServiceCode = isHasAtLeastOneDoneServiceCode();

Если это был бы один метод(допустим первый) я бы это сделал так

Flowable.fromIterable(getUndoneServiceCodes())//
            .subscribeOn(Schedulers.io())//
            .observeOn(AndroidSchedulers.mainThread())//
            .doOnSubscribe(iSubscription ->
            {
                if (iCloseCallListener != null)
                {
                    iCloseCallListener.onPreValidation();
                }
            }).toList()//
            .subscribe(resultList -> {
                if (iCloseCallListener != null)
                {
                    iCloseCallListener.onPostValidation(iCloseCallListener, ???, ???);
                }
            });

Но так я получу результат только для одного выполняемого в бекграунде метода, как сделать так, чтоб можно было обрабоать 3?

1
  • @ЮрийСПб добавил
    – Sirop4ik
    28 янв 2018 в 11:29

1 ответ 1

4

Можно воспользоваться оператором zip как-то так (точность названий методов не гарантирую):

Flowable.zip(
    Flowable.fromCallable(method1()), 
    Flowable.fromCallable(method2()),
    Flowable.fromCallable(method3()),
    (result1, result2, result3) -> new Triple(result1, result2, result3) 
)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(triple -> iCloseCallListener.onPostValidation(triple.first, triple.second, triple.third))
2
  • Да действительно то что нужно, спасибо. Вот только не совсем удобно получается, что вот этот класс Triple - который по сути pojo обьект, так вот получается, что этот обьект занимает кучу строк... Конечно если использовать kolin то вообще проблем нет)
    – Sirop4ik
    28 янв 2018 в 15:03
  • @AlekseyTimoshchenko, да, с котлином проще - там этот класс в стандартную либу входит) Если на Java - то можно просто в массив данные положить - тогда не надо будет лишние классы создавать. Хотя это, конечно, не очень красиво будет)
    – ЮрийСПб
    28 янв 2018 в 15:18

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.