Вопросы по теме 'rx-java'
RxJava Завершение бесконечных потоков
Я изучаю реактивное программирование и RxJava. Это весело, но я застрял на проблеме, на которую не могу найти ответа. Мой основной вопрос: каков соответствующий реактивно способ завершить бесконечно работающий Observable? Я также приветствую...
3729 просмотров
schedule
11.07.2023
Android Studio добавляет библиотеку rxjava
Рассмотрим следующую структуру проекта:
MainProject
-.idea
-.grandle
-src
-SubProject
--libs //I created this folder manually
---rxjava-core-0.16.0-sources.jar
--src
---main //+ all the sources
--build.grandle
--SubProject.iml
-build.grandle...
14555 просмотров
schedule
14.04.2022
Vert.x — RxJava — zip наблюдаемые
Я пытаюсь закрепить наблюдаемые объекты с помощью Vert.x и RxJava. Я не знаю, то ли я что-то неправильно понимаю, то ли это просто какой-то баг. Вот код.
public class BusVerticle extends Verticle {
public void start() {
final...
988 просмотров
schedule
13.12.2022
rxjava: Могу ли я использовать retry (), но с задержкой?
Я использую rxjava в своем приложении для Android для асинхронной обработки сетевых запросов. Теперь я хотел бы повторить неудачный сетевой запрос только по прошествии определенного времени.
Есть ли способ использовать retry () для Observable, но...
51285 просмотров
schedule
15.02.2023
API на основе Observable и проблема с отменой подписки
Я пытаюсь использовать Rx-Java для создания класса для отслеживания местоположения на Android. Чего я до сих пор не могу понять, так это того, как правильно обрабатывать жизненный цикл моего Observable. Я хочу иметь Observable, который начинает...
1910 просмотров
schedule
30.07.2023
Тема RxJava как труба
Я хочу использовать Subject , чтобы создать по существу конвейер между одним Observable и другим без использования карта или flatMap , так как их использование слишком многословно.
Я не могу понять, как это сделать с помощью Subject, хотя...
1149 просмотров
schedule
11.01.2023
Google Appengine и rx-Java?
Совместима ли библиотека rxJava с Google Appengine? Если да, то есть ли ограничения? Единственная информация, которую я нашел, это упоминание о «частичной поддержке» в grepcode....
1244 просмотров
schedule
20.04.2022
Что это за исключение NoSuchMethod с использованием Retrofit with Observables?
Я хочу задокументировать этот ответ здесь, чтобы устранить путаницу для других, которые столкнулись с той же проблемой, что и я. Используя v0.18 rxjava-core и rxjava-android, каждый раз, когда я пытаюсь вернуть Observable из вызова Retrofit, я...
521 просмотров
schedule
24.09.2023
Как дождаться завершения async Observable
Я пытаюсь создать образец с помощью rxjava. Образец должен организовать ReactiveWareService и ReactiveReviewService для повторного запуска композита WareAndReview.
ReactiveWareService
public Observable<Ware> findWares() {...
43344 просмотров
schedule
10.11.2022
Встроенный или рекомендуемый способ повторить цепочку асинхронных операций в RxJava.
У меня есть график взаимозависимых асинхронных операций, смоделированный в RxJava. Для некоторых ошибок весь график должен быть перезапущен. Операторы retry(..) не поддерживают это напрямую, потому что любая ошибка предоставляется всем...
1259 просмотров
schedule
14.01.2023
Цепочка сервисов модернизации с поддержкой RxJava
У меня возникли проблемы с цепочкой наблюдаемых с использованием поддержки модифицированного RxJava. Я, вероятно, неправильно понимаю, как его использовать, иначе это может быть ошибка в модификации. Надеюсь, кто-то здесь может помочь мне понять,...
3413 просмотров
schedule
04.07.2022
RxJava: Окно по количеству или промежутку времени без отбрасывания элементов
Я хочу разделить свой поток на пакеты определенного максимального размера, и если этот размер не будет достигнут через некоторое время, закрыть пакет и начать новый. Для этого я попытался использовать окно (количество):
things.window(10)...
3347 просмотров
schedule
06.09.2022
Обработка сетевой ошибки с помощью наблюдаемого дооснащения
При использовании Observables с Retrofit, как вы справляетесь с сетевыми сбоями?
Учитывая этот код:
Observable<GetJobResponse> observable = api.getApiService().getMyData();
observable
.doOnNext(new Action1<GetJobResponse>() {...
18790 просмотров
schedule
29.03.2023
Как лучше всего отлаживать проблемы RxJava с неполученными сообщениями
У меня есть приложение для Android с несколькими наблюдателями типа A , которые подписываются на несколько Observable типа B . Подписка выполняется в IO Scheduler, а наблюдение — в основном потоке Android.
Проблема, с которой я столкнулся,...
12565 просмотров
schedule
21.04.2024
Почему следует рассмотреть возможность использования AndroidObservables в RxJava
Насколько я понимаю, AndroidObservable помогает убедиться, что:
Подписчик всегда наблюдает за основным потоком
когда фрагмент/активность отсоединяется/останавливается, наблюдение немедленно останавливается, а компоненты, связанные с...
3057 просмотров
schedule
25.05.2022
Отладка zip-оператора RxJava, который останавливается
Написав на Java, я вызываю метод zip(), который получает несколько методов, возвращающих Observable‹...>.
В настоящее время я не могу перейти к следующей карте, и это, вероятно, связано с тем, что один из методов еще не вернул значение. (Хотя...
443 просмотров
schedule
25.02.2023
StickyEvents в Android Observables?
Что эквивалентно getStickyEvent() из EventBus в RxJava.
Я хотел бы подписаться на наблюдаемые с «экранов», которые не находятся на переднем плане/не активны, но в любой момент могут появиться.
Если события происходят постоянно, я хочу, чтобы эти...
182 просмотров
schedule
17.11.2023
модернизация с помощью rxjava, обрабатывающего сетевые исключения в глобальном масштабе
Я пытаюсь обрабатывать исключения в приложении на глобальном уровне, поэтому модификация выдает ошибку, которую я улавливаю в каком-то конкретном классе с логикой для обработки этих ошибок.
У меня есть интерфейс
@POST("/token")
AuthToken...
6676 просмотров
schedule
15.08.2022
Темы RxJava нужны?
Я только начал изучать RxJava и думать реактивно. Я нашел статью (7 советов), в которой говорится, что предметы следует использовать только в крайнем случае или в качестве первой реализации, и я подумал. На данный момент у меня есть один...
814 просмотров
schedule
03.07.2023
Заполнитель для наблюдаемого?
Допустим, у меня есть два Observables A и B. A выдает true, когда служба подключена к моей программе. B выдает true, если служба запущена, иначе false.
Я хочу объединить A и B с помощью combLatest, а затем предпринять соответствующие действия....
214 просмотров
schedule
02.06.2022
