Вопросы с меткой [rxjava]

Java реализация ReactiveX, являющегося API для асинхронного программирования посредством наблюдения за потоками событий

Фильтрация
Сортировка
Метки
1 голос
1 ответ
106 показов

Синхронизация подписки на Observable

O работе с асинхронщиной знаю только теорию, на практике не работал работаю с mongodb-async-driver + mongodb-driver-rx у меня есть запрос на добавление транзакций, который может выполняться из ...
2 голоса
1 ответ
46 показов

Почему subscribeOn() не отправляет предыдущее значение из Behaviour subject?

Изучаю нюансы работы методов subscribeOn() / observeOn() для Subjects. Не могу понять, почему в приведенном коде subscribeOn() запрещает отправку события str 0? val observer: Observer<String&...
0 голосов
0 ответов
29 показов

Как работают Reactive Streams java?

В целом разобрался с механизмом работы Reactive Streams, но не понимаю момент, когда подписчик вызывает метод request(n) подписки(Subscription), чтобы запросить данные у издателя, как тот понимает, ...
2 голоса
1 ответ
153 показа

Как обработать правильно ошибку RxJava2

Вот есть такой код private long getEntireElementsCount(Map<?, Integer> iMap) { return Observable.fromCallable(iMap::values)// .onErrorReturnItem(new ArrayList<>()...
0 голосов
2 ответа
656 показов

Цепочка запросов с помощью RxJava

Мне нужно отправить два запроса POST на сервер. Второй запрос должен быть отправлен только после того как в него "будет вставлен" ответ от первого запроса. В документации вычитал, что для этого нужно ...
1 голос
0 ответов
33 показа

Статус подключения к серверу с помощью rxjava в Android

Имею подключение по websocket object StompWrapper { private var emitter: ObservableEmitter<Event>? = null init { val client = OkHttpClient.Builder().build() val stomp = ...
1 голос
1 ответ
462 показа

Retrofit + RxJava + Unit test

Есть unit test для Retrofit запросы щас мне возвращают типизированые ответы от сервера Call<List<GroupObject>> в таком виде достаточно просто его тестировать: GroupObject group = new ...
1 голос
1 ответ
55 показов

Бесконечный цикл при обновлении в room с использованием rxJava

Все я заккоментил, чтобы найти источник зла. model.updateFavorite(it) он входит в бесконечный цикл. Его код fun updateFavorite(pokemon: PokemonEntity){ Log.d("RefreshFavorite", ...
0 голосов
1 ответ
62 показа

Как сделать вызов асинхронным rxJava

У меня сейчас стоит задача получить список данных из интернета, через retrofit. И если код ответа не успешный(200), то взять этот список данных из бд(room). Как мне сделать это правильно с rxJava? Я ...
1 голос
1 ответ
93 показа

Когда отписываться от Observable?

Доброго времени суток ! пытаюсь разобраться со связкой RxJava + Retrofit в интерфейсе retrofit есть метод возвращающий Single @GET fun getPicture(@Url url: String): Single<ResponseBody> ...
0 голосов
1 ответ
32 показа

Какую аннотацию поставить в функции интерфейса Dao для Rxjava

У меня есть две функции находящиеся в Dao для работы с Rxjava надо пометить аннотацией Single,Completable и т.д. ,но мне выдает ошибку error: Not sure how to convert a Cursor to this method's return ...
0 голосов
1 ответ
904 показа

Java Observer и Observable

Только начинаю погружение в Java. Не могу понять один момент, можем ли мы использовать один наблюдатель - Observer для разных объектов наблюдения - Observable или должно быть строго, один Observer ...
0 голосов
2 ответа
373 показа

Clean Architecture android

Начал в своем MVP юзать интерактор) При этом Rx я не использовал) В Interactor`е я инжектил ретрофит и отправлял запрос) Сейчас изучаю RxJava. Вроде бы принцип понял. Есть Observable и observer. Окей)...
0 голосов
0 ответов
41 показ

Как подписаться на два observable разного типа за раз? rxjava

У меня есть два observable разного типа. val urlContent = contentRepo.getUrlContent(urls).toObservable() val isConnected = Observable.interval(1, TimeUnit.SECONDS).flatMap { ...
0 голосов
1 ответ
56 показов

RxJava сортировка списка по одну из эллементов

Имею json из такими строками как title, time, click_url, img, type, top и тд. Я получаю список эллеметов со строками которые я описал выше. Мне нужно Получить список эллеметов который будет иметь ...
0 голосов
2 ответа
88 показов

Получение Observable<List<B>> из Observable<List<A>>

Есть два метода: fun getMovieActors(id: Long) = provider.retrofit .loadMovieCreditsById(id, WebProvider.API_KEY) .subscribeOn(Schedulers.io()) .map { credits -> ...
1 голос
0 ответов
30 показов

RxJava - как реактивно подставлять наблюдаемые значения (в т.ч. пары) в запрос в Room, который так же возвращает Observable?

Во вьюМодели: val searchQuery = Observable<String> val catNumberOnlyTurnedoff = Observable<Pair<Int, Boolean>> fun getWords(query: String, category: Int, onlyOff: Boolean) : ...
0 голосов
1 ответ
102 показа

Не могу получить данные из LiveData в UI

я новичок в Андроид. Во ViewModel использую liveData(temperature) в которую передаю данные из сервера при помощи RxJava. class WeatherTodayViewModel(application: Application) : AndroidViewModel(...
0 голосов
1 ответ
129 показов

Как правильно реализовать цепочку rxjava в android kotlin?

Я пытаюсь реализовать условия отсутствия интернета на мобильном устройстве. При этом должна происходить такая последовательность операций в цепочке: 1.Проверяем время последнего запроса 2.Делаем ...
1 голос
1 ответ
76 показов

Несколько Api запросов с использованием RxJava и Retrofit

Такой вот вопрос. Мне нужно сделать несколько Api запросов с использованием Retrotit и RxJava. В первом запросе я получаю список из 20 фильмов. Мне нужно выводить список фильмов и инфу под каждым ...
0 голосов
1 ответ
54 показа

Синхронный RxJava запрос

У меня есть OkHttp Interceptor, который добавляет headers к запросам. Проблема в том, что он делает это асинхронно(использую RxJava2) и запрос уходить до модификации Interceptor. Код Interceptor: ...
0 голосов
1 ответ
50 показов

Обьеденить в один метод запрос с серва и запись в базу данных

У меня есть запрос из серва и из базы данных, суть в том, что бы при кадом запуске шла загрузка с базы данных, и с сервера который обновляет эту базу с помощью RxJava 2 Код который я придумал, но ...
0 голосов
2 ответа
56 показов

Как вызвать onError после filter()

Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
1 голос
1 ответ
38 показов

Завершение стримов RxJava при закрытии активности в Android

Разбираюсь с использованием RxJava в Android, возник вопрос следующего рода. Я сделал вот такую extension функцию: fun <T: View> T.setReactiveOnClickListener(): Flowable<View> { val ...
0 голосов
0 ответов
39 показов

RecyclerView, видя два одинаковых подряд объекта, автоматически смещает "камеру" на второй, оставляя впередиидущий сверху вне поля видимости

In the Fragment: @AndroidEntryPoint class DrillerFragment : Fragment(R.layout.cardstack_layout), CardStackListener { private val viewModel: DrillerViewModel by viewModels() private lateinit ...
0 голосов
1 ответ
53 показа

Дублирование ответов от Retrofit 2

я столкнулся с такой проблемой. Я делаю 2 запроса к внешнему API через Retrofit 2 + RxJava 3, но вместо одной строчки ответа они выводят по две. (Если сделать 3 запроса то каждый из них выведет по три ...
0 голосов
0 ответов
39 показов

Мерцает textView при обновлении с помощью rxJava

Есть фрагмет с таким кодом StringObservable.from(inputStream) .subscribeOn(Schedulers.io()) .map(String::new) .map(s-> { Log.d(&...
2 голоса
1 ответ
217 показов

RxJava на поток подписываются сразу несколько подписчиков

Использую RxJava2. На поток подписываются сразу несколько подписчиков (от 2 до N), из-за чего получение данных происходит столько раз, сколько существует подписчиков. Главный класс (NewsPresenter) ...
1 голос
0 ответов
59 показов

Retrofit2 + RxJava. Зачем?

У меня два вопроса: Зачем использовать RxJava при работе с Retrofit2? Единственная причина что я находил - удобство обработки. Если опустить это преимущество, то так ли нужна RxJava сейчас в ...
0 голосов
0 ответов
49 показов

RxJava - как в ViewModel передать метод из Репозитория в LiveData и указать потоки

In Dao: @Query("SELECT * FROM person_table WHERE status = :status_debil ORDER BY RANDOM() LIMIT 5") Single<List<Person>> getFivePersonsFrom(String status_debil); In Repo:...
1 голос
1 ответ
76 показов

RxJava - не пойму как обернуть метод из Dao в Single в Репозитории

In Dao: @Query("SELECT * FROM person_table WHERE status = :status_debil ORDER BY RANDOM() LIMIT 5") List<Person> getFivePersonsFrom(String status_debil); In Repo: public class ...
0 голосов
0 ответов
93 показа

Перенос логики синхронизации с Kotlin корутин на iOS Swift в связке RxSwift+RxAlamofire

Есть некий функционал синхронизации, который хорошо рализован на корутинах. Код-пример ниже: class SyncExample { companion object { const val TAG = "SyncExample" val progress: ...
1 голос
0 ответов
81 показ

RxJava2 + Retrofit2: Почему в интерфейсе Retrofit часто используют именно Observable/Flowable?

Читал разные статьи и смотрел много видео на ютубе по связке RxJava и Retrofit, и очень часто видел примерно одну и ту же конструкцию: @GET("some/endpoint") fun getSomeData(): Observable<...
0 голосов
1 ответ
226 показов

Задача на rxJava

У нас есть Observable<Int> который эммитит разные числа. Нам надо встать между Observable и подписчиком и смотреть когда к нам в onNext приходит число "x" то мы увеличиваем счетчик на единицу и ...
1 голос
1 ответ
81 показ

Реализация мгновенного поиска c RxJava

Пытаюсь делать в своем приложении мгновенный поиск пользователей из удаленной БД с RxJava. Следуя по одной статьи получилось сделать так: Сначала мне приходится получить всех пользователей,а потом ...
0 голосов
1 ответ
325 показов

В каком потоке выполняется subscribe() в RxJava?

У меня есть метод getText(), который получает из сети текст. Его нужно вставить в TextView. protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); ...
2 голоса
0 ответов
35 показов

Тестирование аргументов переданных в Observable RxJava

Есть некий метод: repository.get(arg1, arg2, arg3) Который возвращает Single<List<SomeObject>> Мне нужно протестировать, что на этот Single происходит подписка. Как протестировать ...
1 голос
1 ответ
230 показов

Android MVVM как получить ответ от ViewModel во View

У меня есть активити, у нее есть viewmodel. Viewmodel во время инициализации скачивает с сервера с помощью retrofit данные в json. Эти данные преобразуются в список объектов во viewmodel. И теперь мне ...
1 голос
1 ответ
281 показ

Android RxJava: как правильно подписать PublishSubject на множество Observable?

Буду благодарен за любые подсказки и варианты как это поправить. Задача: выдавать результаты вычислений асинхронно, по готовности. Пример составлен для теста из рабочего кода, его можно использовать в ...
0 голосов
1 ответ
94 показа

WorkManager vs Rxjava

В чем разница между WorkManager и Rxjava? При каких обстоятельствах что использовать (примеры задач, пожалуйста)?
1 голос
1 ответ
82 показа

RxJava map vs Kotlin map

Раньше когда был Java 6 и Rx, при использовании RX подхода, делал mapping так Single.just(listOf("1", "2", "3", "4")) .toObservable() ....
1 голос
1 ответ
76 показов

Как правильно сделать асинхронные запросы, зависящие друг от друга RxJava Android

я новичек в RxJava. Задача следующая: есть 3 запроса Получение токена Валидация токена Получение id сессии Каждый запрос зависит от ответа предыдущего, т.е. сначала я делаю запрос на получение ...
0 голосов
0 ответов
73 показа

При использовании RxJava обновления подписчику не приходят

Я только начал изучать RxJava и столкнулся с проблемой. У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri) public Observable<Uri> get() { ...
0 голосов
0 ответов
26 показов

По какой причине GSON может отдавать null?

Имеется стандартная связка в виде API Service (Retrofit + RxJava2CallAdapterFactory, GsonConverterFactory). Почему-то подписка сыпалась с null pointer в onError. Стал разбираться. Оказывается, null ...
0 голосов
1 ответ
77 показов

Как получить данные из БД Room с помощью RxJava если с удаленного сервера пришла ошибка

Всем привет. Пишу приложение в котором запрашивается погода с удаленного сервера. Для Api запроса использую библиотеку Retrofit и RxJava. Сейчас мне нужно добавить в приложение БД Room, если при Api ...
1 голос
0 ответов
59 показов

Подписка на обновления на сервере RxJava

В приложении на сервер загружается картинка. Эту картинку надо скачать и отобразить, но проблема в том, что она ещё не успевает загрузиться в базу данных. Хочу исправить это с помощью RxJava. Читал,...
0 голосов
1 ответ
91 показ

не сохраняются данные в переменную в методе subscribe() RxJava

Всем привет. Не могу понять почему в теле метода subscrube() я присваиваю значение переменной coordinates,и сразу же вывожу значение переменной coordinates в Log и мне отображает нужный мне результат ...
1 голос
1 ответ
54 показа

Как вы используете в своём проекте связку Rx и ButterKnife?

Пилю собственное приложение и хотелось бы узнать мнение опытных программистов по поводу связок библиотек для написания структурированного, красивого кода. На данный момент в проекте есть GSON, ...
3 голоса
2 ответа
112 показов

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

Необходимо получать из репозитория все выбранные объекты (isSelected). Есть DataRepository - который возвращает Flowable<List<Data>>, данные беру из Room`а: fun getSelectObjects(): ...
2 голоса
0 ответов
43 показа

Как избежать слишком частого повторного рендера RecyclerView при использовании Flowable (RxJava)?

Реализую MVVM с room + flowable из rxjava + retrofit2. При открытии активити из репозитория мне прилетает FLowable со списком элементов из БД (room). В этот же момент репозиторий запрашивает список у ...