Вопросы по теме 'rx-java2'
Как обрабатывать ответ «Нет содержимого» с помощью RxJava2 и Retrofit2
Я использую RxJava 2 и Retrofit 2 ( https://github.com/JakeWharton/retrofit2-rxjava2-adapter ), и мне было интересно, как справиться с типом отсутствия ответа (204). В rxjava1 я использовал Observable<Void> , но rxjava2 больше не разрешает...
1005 просмотров
schedule
15.09.2022
Обратное давление с Vertx HttpClient и RxJava
У меня проблемы с созданием «системы противодавления». Я использую Vertx HttpClient и RxJava. Мне нужно сделать 6000 запросов к внешней службе, и, чтобы избежать переполнения в waitForQueue, поскольку эта внешняя служба не может обрабатывать так...
661 просмотров
schedule
09.12.2023
RxJava2: невозможно обработать исключение для асинхронного обратного вызова с помощью retryWhen
Я пытаюсь подключиться к брокеру MQTT. Я хочу повторить попытку, если мне не удастся подключиться. Я получаю обратный вызов при успешном или неудачном подключении.
Прочитав несколько примеров retryWhen и обработки асинхронных обратных вызовов, я...
1284 просмотров
schedule
10.09.2022
RxJava (Android) — есть ли вред в сохранении планировщика?
У меня есть синглтон, который содержит ссылку на мой объект базы данных. Что я хотел бы сделать, так это ограничить любую операцию базы данных одним потоком ввода-вывода.
Сначала я попробовал следующее:
class SQLSingleton{
...
public...
1127 просмотров
schedule
10.02.2024
Создание пользовательских операторов в RxJava2?
У меня проблемы с поиском примера того, как создать собственный оператор с помощью RxJava 2. Я рассмотрел несколько подходов:
Использование Observable.create , а затем flatMap ing на нем из наблюдаемого источника. Я могу заставить это...
2915 просмотров
schedule
05.07.2022
Горячее завершение с длительными задачами
По умолчанию Completable не горячий. Но у меня есть случай, когда горячий Completable был бы действительно полезен: загрузка и кеширование набора больших файлов:
class DownloadManager {
Completable downloadAndCacheA();
Completable...
645 просмотров
schedule
13.06.2023
Как ввести задержку в группе RxJava, обрабатываемой параллельно?
Мой вариант использования — сгруппировать поток, запустить параллельную обработку некоторых групп и внутри каждой группы отложить обработку каждого элемента на постоянный интервал. Кажется, я не могу правильно понять задержку внутри группы, потому...
1370 просмотров
schedule
13.08.2022
Невозможно запросить использование области
Я использую Realm вместе с RxJava, и в конце я хочу получить наблюдаемое, которое я могу использовать:
@Override
public Observable<List<Data>> getData_List() {
final Observable<RealmResults<Data>> observable...
320 просмотров
schedule
06.03.2023
Экземпляр Realm уже закрыт, что делает его непригодным для использования
Функция fetchData находится во фрагменте. Класс dataRepository содержит функцию, которую я использую для извлечения данных с диска:
@Override
public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {...
1594 просмотров
schedule
18.04.2023
RxJava2 flatMap создает повторяющиеся события
Я относительно новичок в RxJava2, и у меня странное поведение, поэтому, вероятно, я использую этот инструмент не так, как надо.
Это довольно большой проект, но я выделил приведенный ниже фрагмент как минимально воспроизводимый код:
Observable...
1313 просмотров
schedule
02.01.2023
RxJava: преобразование потока отдельных элементов в список
Я пытаюсь понять, как получить ответ, который возвращает список элементов, затем сделать запрос для каждого из этих элементов, который вернет объект, а затем объединит все ответы в список.
У меня он работает, отправляя их по одному, но я хотел бы...
1301 просмотров
schedule
04.06.2022
Выполнить 2 наблюдаемых последовательно и сразу получить результат — RxJava 2
У меня есть эта функция:
public static class CombinedResult<T, R> {
T t;
R r;
public CombinedResult(T t, R r) {
this.t = t;
this.r = r;
}
public T getObject1() {
return t;
}
public void...
2867 просмотров
schedule
04.11.2022
RxJava2 Как поделиться наблюдаемым с двумя другими наблюдателями и объединить его обратно с подписчиком
У меня есть следующие методы
Document createDocument(String url);
List<MediaContent> getVideo(Document doc);
List<MediaContent> getImages(Document doc);
List‹ MediaContent> будет потребляться
void...
1055 просмотров
schedule
08.07.2022
RXJava, как асинхронно выполнить два наблюдаемых объекта, запустить функцию после завершения обоих и получить разницу во времени между обоими потоками?
Я ищу элегантный способ запуска двух наблюдаемых одновременно, дождаться завершения обоих (они оба получают данные из Интернета) и только после того, как оба выполнят функцию.
Мне также нужно получить разницу во времени между двумя потоками? Есть...
67 просмотров
schedule
04.10.2023
Как связать два Completable в RxJava2
У меня два Completable. Я хотел бы выполнить следующий сценарий: если первая Completable перейдет к onComplete, продолжите со второй Completable. Окончательные результаты будут на Завершение второй Завершенной таблицы.
Вот как я это делаю, когда...
36317 просмотров
schedule
18.05.2023
Вызов subject.onNext () внутри doOnSubscribe
Почему вызов subject.onNext(o) внутри doOnSubscribe не дает никакого эффекта, однако вызов subject.onComplete() приводит к завершению потока !?
final PublishSubject<Integer> subject = PublishSubject.create();
final...
575 просмотров
schedule
12.04.2022
RXJava передает значение в onComplete
Я использую RXJava 2. После некоторой логики в методе subscribe я хочу удалить используемый файл. Думаю, мне следует сделать это в onComplete . Но я не могу передать туда свой объект File . Мой код: Вопросы:
Observer<Bitmap> observer...
4840 просмотров
schedule
20.08.2023
Как использовать if-else в цепочке RX java?
Я новичок в RXJava/RXAndroid. Я хочу реализовать этот случай: выбрал другой способ, основанный на каком-то условии в RXJava. Например, сначала я получаю информацию о пользователе из сети, и если это пользователь VIP, я продолжаю получать...
22674 просмотров
schedule
21.09.2022
Android RxJava2 множественная проверка EditText
Мне нужно проверить 7 полей перед вызовом остальных. Каждая проверка является единственной наблюдаемой, которая выдает ошибку, если строка не соответствует правилам. В методе onError мне удается в каком поле отображать сообщение об ошибке и текст...
483 просмотров
schedule
08.03.2024
RxJava: наблюдать, подписываться и делать, наконец, переключение между потоками ввода-вывода и пользовательского интерфейса.
Я столкнулся с проблемой, когда мой наблюдаемый объект подписывается на поток ввода-вывода и наблюдается в основном потоке (UI) Android, но оператор doFinally запускается в потоке ввода-вывода, и его нужно запускать в потоке пользовательского...
4513 просмотров
schedule
10.06.2023
