2

Здравствуйте! Никак не могу понять, как перевести простой AsyncTask в RxJava. Возьмем для примера:

private class Sync extends AsyncTask<String, String, String> {

    @Override
    protected String doInBackground(String... params) {
              String proxy_arr = "";
                    try {
                        Document jsoup_proxy = Jsoup.connect(Constants.SITE_PROXY_LIST)
                                .userAgent(Constants.USER_AGENT)
                                .ignoreContentType(true)
                                .ignoreHttpErrors(true)
                                .timeout(Constants.USER_TIMEOUT)
                                .get();

                        if (jsoup_proxy != null) proxy_arr = jsoup_proxy.text().trim();
                    } catch (IOException e) {
                        new DebugLog(getActivity(), "News", "Sync PROXY", Log.getStackTraceString(e));
                    }
              return proxy_arr;
    }

    @Override
    protected void onPostExecute(String result) {
        if (result.equals("err_internet")){
            func.toastMessage(R.string.toast_err_nointernet, "", "alert");
        }

        reloadAdapter();
    }
}

Как его можно перевести, в такое же рабочее состояние с RxJava? Спасибо!

2
  • зачем переводить на RXJava, если ты не знаешь RX?) 25 июл 2017 в 16:37
  • понять принцип и отличия
    – SmallSani
    27 июл 2017 в 0:35

1 ответ 1

4
Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> observer) {

                if (!observer.isUnsubscribed()) {
                    String proxy_arr = "";
                    //код из doInBackground()

                    observer.onNext(proxy_arr);
                    observer.onCompleate();
                }
            }
        })
        .subscribeOn(Schedulers.newThread()) // указываем поток, в котором будет работать Observable
        .observeOn(AndroidSchedulers.mainThread()) // указываем поток, в который будет передаваться результат из onNext
        .subscribe(new Action1<String>() {
                        @Override
                        public void call(String town) {
                            //код из onPostExecute
                        }
                    });

Observable.create() создает новый Observable который будет испускать данные. В эту функцию передается реализация Observable.OnSubscribe в котором и будет выполняться вся работа. Когда результат готов, то вызываем метод onNext() с полученным результатом. Далее этот результат будет передан в метод call объекта Action1.

Методы subscribeOn() и observeOn() указывают на то, в каком потоке должна происходить работа объектов Observable.OnSubscribe и Action1.

Так же к Observable можно добавлять различный методы, например onErrorReturn(), map(), flatMap() и т.д. Полный список операторов можно найти в официальной документации.. Для использования AndroidSchedulers необходимо подключить к проекту Android Module. При использовании rxJava советую использовать библиотеку Retrolambda. Она позволит использовать лямбды, ссылки на методы и некоторые другие фишки Java 8 и улучшит читаемость кода.

Так же есть хорошие статьи по этой теме на хабре.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

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