15
голосов
Принятый
Зачем нужен RxJava в Android?
RxJava - это библиотека, которая реализует реактивный подход к программированию. Что такое реактивное программирование можно почитать на сайте проекта ReactiveX API.
ReactiveX is a combination of ...
11
голосов
Принятый
Назначение RxJava, RxAndroid
RxJava - либа для обработки событий как последовательностей. Надстройка над паттерном "наблюдатель", умеет по-всякому преобразовывать последовательности событий и так далее. Либу можно заюзать где ...
11
голосов
Принятый
Различие между subscribeOn и observeOn методами
Нашла полезную статью, которая содержит точный ответ насчёт количества и места вызова данных методов. Надеюсь, поможет кому-нибудь ещё.
По поводу subscribeOn()
The subscribeOn() operator will have ...
10
голосов
Принятый
Как обработать данные с помощью RxJava в Android
Должно быть как то так:
ApiInterface api = ApiModule.getClient(); // создадим только один сервис с апи, не надо дергать getClient() несколько раз
api.getActiveSimpleOrder(1) // запрашиваем список
...
7
голосов
Не получается создать пустой Observable
Если вы создаете Observable методом Observable.empty, то такой Observable выдаст только событие onCompleted и больше ничего, т.е. событие onNext никогда не будет вызвано и ваш код, подписанный (в ...
6
голосов
Принятый
Как в Retrofit отправлять запросы через определенный период времени?
Можно 2 способами:
Использовать оператор repeatWhen так:
private void getCrypto() {
Subscription subscription = BaseApi.getInstance().service.getCrypto()
.subscribeOn(Schedulers.io())...
6
голосов
Принятый
Правильное выполнение запроса RxJava+Retrofit
Например как-то так:
Получаем массив чатов.
Преобразуем массив оных в очередь объектов Chat.
Получаем детали каждого.
Результат преобразовываем обратно в массив:.
apiService.getChats()
.from(...
5
голосов
Принятый
Поворот экрана с MVP, Android, RxJava,
В общем есть отличная библиотека, чтобы жить без боли ЖЦ при mvp архитектуре. https://github.com/Arello-Mobile/Moxy
Сам использую в нескольких проектах, и всем советую.
5
голосов
Принятый
Обработка множественных запросов на RxJava
Как вариант можно хранить Subscription и её сначала обнулять, а потом новый запрос слать. Типа как-то так (за названия методов не ручаюсь):
Subscription s;
public void loadUsers() {
if(s ...
4
голоса
Принятый
AsyncTask в RxJava
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> observer) {
if (!observer....
4
голоса
Принятый
AlertDialog с помощью RxJava
Самый простой способ это заюзать метод from:
List<String> list = new ArrayList<>();
for (int i = 0; i < 100; i++) {
list.add("item "+i);
}
Observable.from(...
4
голоса
Принятый
java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT (Retrofit 2)
Сервер присылает JSONObject, в котором JSONArray, а вы пытаетесь парсить как JSONArray. Должно быть как то так:
public class GroupList {
ArrayList<Group> group;
//setters, getters
}
...
4
голоса
Принятый
RxJava Android: выполнить метод в другом потоке для каждого элемента списка
Дело в том, что после observeOn(AndroidSchedulers.maintThread()), все будет выполняться в UI-потоке. Принцип прост:
someObservable
//все вызовы здесь будут выполняться в THREAD_1
.subscribeOn(...
4
голоса
Как с помощью RxJava посчитать сумму в Observable<Integer>?
sumInteger() - метод класса MathObservable входящего в rxjava-math. Если эта библиотека есть в зависимостях, то можно так:
Observable<Integer> numbers = Observable.just(1, 3, 4, 6, 3);
Integer ...
4
голоса
Принятый
Насколько мой код приемлемый
Если вы используете rx, то вам не надо использовать Trhead, rx все сделает.
Надо только указать subscribeOn(Schedulers.io())в цепочке операторов, для выполнения в фоне.
Также обернуть insert в ...
4
голоса
Почему происходит и как избавится от NetworkOnMainThreadException?
Если не указывать явно в каком потоке должен выполняться код в Observable, то он будет выполняться в потоке, исполняющем инициализацию оного. В вашем случае это главный, UI поток.
Вам надо явно ...
4
голоса
Методы just в RxJava
Вероятно, это сделано, чтобы эти статические методы можно было приводить к функциональным интерфейсам семейства rx.functions.Func*
public interface Func1<T, R> extends Function {
R call(T t)...
4
голоса
Принятый
Как правильно заменить AsyncTask с помощью RxJava2 и RxAndroid2
Можно воспользоваться оператором zip как-то так (точность названий методов не гарантирую):
Flowable.zip(
Flowable.fromCallable(method1()),
Flowable.fromCallable(method2()),
Flowable....
4
голоса
Принятый
Как превратить EditText в поток данных для RxJava2?
Можно воспользоваться готовой библиотекой RxBinding. Также в ней можно посмотреть конкретную реализацию.
Вообще для связки callback-методов с rx используется метод Observable.create, например:
...
4
голоса
Принятый
Как правильно вынести метод из flatMap?
Все очень просто:
выносите лямбду в отдельный метод с соотвествующей сигнатурой
private static Observable<AuthorizationEntity> parse(Response<ResponseBody> responseBodyResponse)
в ...
4
голоса
Принятый
Как сделать 2 запроса в rx java?
Observable.fromCallable{ service1.getUser() }
.filter { user -> user.isValid() }
.flatMap { user -> Observable.fromCallable { service2.getData(user) }}
4
голоса
Принятый
Как собрать Maybe<List<User>> из Maybe<User>?
Предлагаю лучше возвращать Single вместо Maybe, тогда реализовать можно, например, так:
Single<List<User>> getUsers(List<Integer> ids) {
return Observable.fromIterable(ids)
...
4
голоса
Принятый
RxJava экзепшен CalledFromWrongThreadException при subscribe
В моем случае
get()
.subscribeOn(Schedulers.io()) //переход в поток вычислений
.observeOn(AndroidSchedulers.mainThread()) // переход в UI поток
.delay(5, TimeUnit.SECONDS) ...
4
голоса
Принятый
Сбросить слушателя с кнопки RxJava
Чтобы сбросить слушатель нажатий надо в метод установки оного передать null
button.setOnClickListener(null)
Также есть уже библиотека, в которой всё это (и многое другое) реализовано: RxBinding
В ...
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....
4
голоса
Принятый
Уведомление из Room пустым списком - Flowable из Room
Можно сделать так:
Room Dao:
@Query("SELECT * FROM Entity WHERE isChecked = 1")
fun getCheckedData(): Flowable<List<Entity>>
@Query("SELECT COUNT(*) FROM Entity WHERE ...
3
голоса
Принятый
RxJava: возвращать Observable после паузы
Блокировать поток нельзя, нужно использовать таймеры.
Пока я смог добиться задержки таким способом, но она занимает заметно больше, чем секунду. Я добавил Scheduler, поскольку без него результат не ...
3
голоса
Принятый
Как правильно пересоздать закэшированный Observable используемый вместе с Retrofit?
В итоге сделал так:
Как верно написал @mit, метод cache() кэшировал запрос и пересоздание observable в итоге не перезапускало сетевой запрос. При этом в доках и в интернетах я нигде сему упоминания ...
3
голоса
Как правильно пересоздать закэшированный Observable используемый вместе с Retrofit?
Не претендую на лучшую реализацию, но...
Лично я у себя во избежания повторных запросов держу данные отдельно от любой активити, дабы не захламлять код.
Есть некий класс, который всегда создается в ...
Only top scored, non community-wiki answers of a minimum length are eligible
Связанные метки
rxjava × 243android × 205
java × 109
rxandroid × 59
rxjava2 × 41
retrofit × 37
kotlin × 35
retrofit2 × 10
android-room × 9
room × 7
recyclerview × 5
mvvm × 5
mvp × 5
livedata × 5
многопоточность × 4
rest × 4
okhttp × 4
архитектура × 3
lambda × 3
observer × 3
android-studio × 2
vkontakte-api × 2
юнит-тесты × 2
map × 2
android-asynctask × 2