Популярные ответы с меткой

15 голосов
Принятый

Зачем нужен RxJava в Android?

RxJava - это библиотека, которая реализует реактивный подход к программированию. Что такое реактивное программирование можно почитать на сайте проекта ReactiveX API. ReactiveX is a combination of ...
rjhdby's user avatar
  • 13.9k
11 голосов
Принятый

Назначение RxJava, RxAndroid

RxJava - либа для обработки событий как последовательностей. Надстройка над паттерном "наблюдатель", умеет по-всякому преобразовывать последовательности событий и так далее. Либу можно заюзать где ...
Big Fan's user avatar
  • 518
11 голосов
Принятый

Различие между subscribeOn и observeOn методами

Нашла полезную статью, которая содержит точный ответ насчёт количества и места вызова данных методов. Надеюсь, поможет кому-нибудь ещё. По поводу subscribeOn() The subscribeOn() operator will have ...
Ksenia's user avatar
  • 10.7k
10 голосов
Принятый

Как обработать данные с помощью RxJava в Android

Должно быть как то так: ApiInterface api = ApiModule.getClient(); // создадим только один сервис с апи, не надо дергать getClient() несколько раз api.getActiveSimpleOrder(1) // запрашиваем список ...
xkor's user avatar
  • 5,011
7 голосов

Не получается создать пустой Observable

Если вы создаете Observable методом Observable.empty, то такой Observable выдаст только событие onCompleted и больше ничего, т.е. событие onNext никогда не будет вызвано и ваш код, подписанный (в ...
mit's user avatar
  • 2,306
6 голосов
Принятый

Как в Retrofit отправлять запросы через определенный период времени?

Можно 2 способами: Использовать оператор repeatWhen так: private void getCrypto() { Subscription subscription = BaseApi.getInstance().service.getCrypto() .subscribeOn(Schedulers.io())...
ЮрийСПб's user avatar
  • 69.8k
6 голосов
Принятый

Правильное выполнение запроса RxJava+Retrofit

Например как-то так: Получаем массив чатов. Преобразуем массив оных в очередь объектов Chat. Получаем детали каждого. Результат преобразовываем обратно в массив:. apiService.getChats() .from(...
ЮрийСПб's user avatar
  • 69.8k
5 голосов
Принятый

Поворот экрана с MVP, Android, RxJava,

В общем есть отличная библиотека, чтобы жить без боли ЖЦ при mvp архитектуре. https://github.com/Arello-Mobile/Moxy Сам использую в нескольких проектах, и всем советую.
andreich's user avatar
  • 6,054
5 голосов
Принятый

Обработка множественных запросов на RxJava

Как вариант можно хранить Subscription и её сначала обнулять, а потом новый запрос слать. Типа как-то так (за названия методов не ручаюсь): Subscription s; public void loadUsers() { if(s ...
ЮрийСПб's user avatar
  • 69.8k
4 голоса
Принятый

AsyncTask в RxJava

Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> observer) { if (!observer....
temq's user avatar
  • 5,847
4 голоса
Принятый

AlertDialog с помощью RxJava

Самый простой способ это заюзать метод from: List<String> list = new ArrayList<>(); for (int i = 0; i < 100; i++) { list.add("item "+i); } Observable.from(...
Alexey Shtanko's user avatar
4 голоса
Принятый

java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT (Retrofit 2)

Сервер присылает JSONObject, в котором JSONArray, а вы пытаетесь парсить как JSONArray. Должно быть как то так: public class GroupList { ArrayList<Group> group; //setters, getters } ...
katso's user avatar
  • 11k
4 голоса
Принятый

RxJava Android: выполнить метод в другом потоке для каждого элемента списка

Дело в том, что после observeOn(AndroidSchedulers.maintThread()), все будет выполняться в UI-потоке. Принцип прост: someObservable //все вызовы здесь будут выполняться в THREAD_1 .subscribeOn(...
Vladimir Parfenov's user avatar
4 голоса

Как с помощью RxJava посчитать сумму в Observable<Integer>?

sumInteger() - метод класса MathObservable входящего в rxjava-math. Если эта библиотека есть в зависимостях, то можно так: Observable<Integer> numbers = Observable.just(1, 3, 4, 6, 3); Integer ...
Sergey Gornostaev's user avatar
4 голоса
Принятый

Насколько мой код приемлемый

Если вы используете rx, то вам не надо использовать Trhead, rx все сделает. Надо только указать subscribeOn(Schedulers.io())в цепочке операторов, для выполнения в фоне. Также обернуть insert в ...
andreich's user avatar
  • 6,054
4 голоса

Почему происходит и как избавится от NetworkOnMainThreadException?

Если не указывать явно в каком потоке должен выполняться код в Observable, то он будет выполняться в потоке, исполняющем инициализацию оного. В вашем случае это главный, UI поток. Вам надо явно ...
ЮрийСПб's user avatar
  • 69.8k
4 голоса

Методы just в RxJava

Вероятно, это сделано, чтобы эти статические методы можно было приводить к функциональным интерфейсам семейства rx.functions.Func* public interface Func1<T, R> extends Function { R call(T t)...
Nofate's user avatar
  • 34.3k
4 голоса
Принятый

Как правильно заменить AsyncTask с помощью RxJava2 и RxAndroid2

Можно воспользоваться оператором zip как-то так (точность названий методов не гарантирую): Flowable.zip( Flowable.fromCallable(method1()), Flowable.fromCallable(method2()), Flowable....
ЮрийСПб's user avatar
  • 69.8k
4 голоса
Принятый

Как превратить EditText в поток данных для RxJava2?

Можно воспользоваться готовой библиотекой RxBinding. Также в ней можно посмотреть конкретную реализацию. Вообще для связки callback-методов с rx используется метод Observable.create, например: ...
Dmitry Ikryanov's user avatar
4 голоса
Принятый

Как правильно вынести метод из flatMap?

Все очень просто: выносите лямбду в отдельный метод с соотвествующей сигнатурой private static Observable<AuthorizationEntity> parse(Response<ResponseBody> responseBodyResponse) в ...
Artem Konovalov's user avatar
4 голоса
Принятый

Как сделать 2 запроса в rx java?

Observable.fromCallable{ service1.getUser() } .filter { user -> user.isValid() } .flatMap { user -> Observable.fromCallable { service2.getData(user) }}
Николай Конорев's user avatar
4 голоса
Принятый

Как собрать Maybe<List<User>> из Maybe<User>?

Предлагаю лучше возвращать Single вместо Maybe, тогда реализовать можно, например, так: Single<List<User>> getUsers(List<Integer> ids) { return Observable.fromIterable(ids) ...
Vadik Sirekanyan's user avatar
4 голоса
Принятый

RxJava экзепшен CalledFromWrongThreadException при subscribe

В моем случае get() .subscribeOn(Schedulers.io()) //переход в поток вычислений .observeOn(AndroidSchedulers.mainThread()) // переход в UI поток .delay(5, TimeUnit.SECONDS) ...
DuosDuo's user avatar
  • 1,640
4 голоса
Принятый

Сбросить слушателя с кнопки RxJava

Чтобы сбросить слушатель нажатий надо в метод установки оного передать null button.setOnClickListener(null) Также есть уже библиотека, в которой всё это (и многое другое) реализовано: RxBinding В ...
ЮрийСПб's user avatar
  • 69.8k
4 голоса
Принятый

Как работает метод notifyDataSetChanged() в RecyclerView

Замените @Override public void onBook(List list) { books = list; Log.d("My_Tag", "Уведомить адаптер " + list.size() + " " + books.size()); Log.d("My_Tag", "адаптер " + rc); rc....
Alex_Skvortsov's user avatar
4 голоса
Принятый

Уведомление из Room пустым списком - Flowable из Room

Можно сделать так: Room Dao: @Query("SELECT * FROM Entity WHERE isChecked = 1") fun getCheckedData(): Flowable<List<Entity>> @Query("SELECT COUNT(*) FROM Entity WHERE ...
Ilnar's user avatar
  • 540
3 голоса
Принятый

RxJava: возвращать Observable после паузы

Блокировать поток нельзя, нужно использовать таймеры. Пока я смог добиться задержки таким способом, но она занимает заметно больше, чем секунду. Я добавил Scheduler, поскольку без него результат не ...
xkor's user avatar
  • 5,011
3 голоса
Принятый

Как правильно пересоздать закэшированный Observable используемый вместе с Retrofit?

В итоге сделал так: Как верно написал @mit, метод cache() кэшировал запрос и пересоздание observable в итоге не перезапускало сетевой запрос. При этом в доках и в интернетах я нигде сему упоминания ...
ЮрийСПб's user avatar
  • 69.8k
3 голоса

Как правильно пересоздать закэшированный Observable используемый вместе с Retrofit?

Не претендую на лучшую реализацию, но... Лично я у себя во избежания повторных запросов держу данные отдельно от любой активити, дабы не захламлять код. Есть некий класс, который всегда создается в ...
Chaynik's user avatar
  • 3,892

Only top scored, non community-wiki answers of a minimum length are eligible