Вопросы по теме 'rx-java'
Если вызов onComplete выполняется для RxJava Subject, нужно ли мне вручную отказываться от подписки снова?
Я использую RxJava ReplaySubject в своем фрагменте.
Я пытаюсь использовать ReplaySubject таким образом, чтобы я хотел, чтобы Subject выполнял процесс до завершения (возможно, за пределами жизненного цикла фрагмента).
По завершении процесса я...
15679 просмотров
schedule
24.10.2022
Проблемы при слиянии выборки Observable
Я использую rx-scala, который является подпроектом rx-java. Я буду использовать синтаксис Scala и надеюсь, что все меня поймут.
Я сталкиваюсь со странным поведением, и я не знаю, является ли это ошибкой или неправильным использованием операторов rx...
73 просмотров
schedule
30.01.2024
Один наблюдаемый два наблюдателя
Есть ли в RxJava какой-либо объект, кроме ConnectableObservable<> , который позволяет иметь несколько подписок на Observable? Например конкретный предмет?
Например. для данного предмета ниже:
private PublishSubject<Location>...
641 просмотров
schedule
01.03.2024
Как применить оператор RxJava?
У меня есть следующая структура объекта
class Object1 {
A[] item1; //array of Object A
B[] item2; //array of Object B
C[] item3; //array of Object C
}
class C {
int value1;
int value2;
String imageUrl; //null, to be updated...
75 просмотров
schedule
11.02.2024
Сделайте что-нибудь с данными только для чтения, используя наблюдаемый поток в RxJava
Интересно, как я могу что-то сделать с данными, которые Observable испускает в потоке Observable, без изменения данных. Например, я запрашиваю список задач с сервера и распечатываю их.
//Assume that taskService.getTasks returns an...
143 просмотров
schedule
14.10.2022
Как абстрагироваться от оборудования с помощью RXJava и Observables без субъектов?
Я работаю над проектом, в котором у меня есть аппаратное устройство, разговаривающее с моим Android-приложением через USB-кабель. Буферы протокола, завернутые в тонкий слой сериализации, — это мой протокол связи.
В настоящее время связь USB...
347 просмотров
schedule
19.01.2024
RxJava groupBy и последующие операции блокировки (onComplete отсутствует?)
Я свел свою проблему к следующему фрагменту:
Observable<Integer> numbers = Observable.just(1, 2, 3);
Observable<GroupedObservable<Integer,Integer>> outer = numbers.groupBy(i->i%3);...
412 просмотров
schedule
09.01.2024
Минимальное время выполнения Rxjava?
У меня есть Observable A и Observable B. Теперь мне нужно дождаться завершения этих Observables или хотя бы 30 секунд. Как я могу добиться этого на RxJava?
Спасибо за любое предложение!
1095 просмотров
schedule
18.09.2022
Использование RxJava для привязки ViewHolder к RecyclerViewAdapter
Я использую RxJava для передачи данных в ViewHolder, а внутри ViewHolder я использую RxJava для заполнения TextView.
Но иногда TextViews все еще пусты. Я думаю, что это проблема времени, но я не знаю, как ее решить :-(
Это важные методы моего...
1280 просмотров
schedule
09.06.2024
RxJava как шина событий?
Я начинаю изучать RxJava, и пока мне это нравится. У меня есть фрагмент, который связывается с действием при нажатии кнопки (чтобы заменить текущий фрагмент новым фрагментом). Google рекомендует использовать interface для взаимодействия фрагментов...
3452 просмотров
schedule
24.12.2023
Отсортированный вывод RxJava из параллельных вычислений
У меня есть список задач, которые я хочу выполнять параллельно, но я хочу отобразить результат задач в том же порядке, что и исходный список. Другими словами, если у меня есть список задач [A,B,C], я не хочу показывать B-результат до того, как я...
622 просмотров
schedule
06.08.2022
Как протестировать активность с помощью RxBindings и Espresso
Я использую RxBindings для прослушивания выбора на вкладке Tab Layout следующим образом:
RxTabLayout.selections(tabLayout).subscribe(tab -> {
// do something
}
Тест Эспрессо никогда не прекращается. Как я могу написать...
317 просмотров
schedule
29.04.2024
Наблюдается для пакетной обработки, например, Lmax Disruptor
Те, кто знаком с кольцевым буфером lmax (disruptor) , знают, что одно из самых больших преимуществ этого Структура данных заключается в том, что она группирует входящие события, и когда у нас есть потребитель, который может воспользоваться...
707 просмотров
schedule
16.11.2023
Как вызвать RxJava Observable без немедленной подписки?
У меня есть метод java, который возвращает шаблон строки. Я хочу сделать 2 асинхронных вызова к удаленному API, каждый вызов будет возвращать число, затем я хочу вычислить сумму этих двух чисел и поместить ее в шаблон перед ее возвратом.
Итак, у...
2028 просмотров
schedule
07.06.2024
Как получить ответ на onError внутри Rxjava
Я использую Retrofit 2.0 в своем проекте с интерфейсом Observable и оболочкой Result. Метод:
Observable<CompanyModel> companyList(@Query("userAcc") String userAcc,
@Query("password") String password);...
936 просмотров
schedule
08.10.2023
Как запустить 2 запроса последовательно в Android RxJava Observable?
Я хочу запустить 2 асинхронных задачи, одну за другой (последовательно). Я что-то читал про ZIP или Flat, но не очень понял...
Моя цель - загрузить данные из локального SQLite, а когда он завершится, он вызовет запрос на сервер (удаленный)....
13268 просмотров
schedule
07.11.2022
RxJava с операциями SQlite и ContentProvider
Я изучаю RxJava, и для этого я играю с SQLite, пишу вспомогательный класс SQLiteUtils , чтобы упростить обработку асинхронных запросов ContentResolver. Например, это метод queryInBackground :
static
public <T> Observable<T>...
3238 просмотров
schedule
18.03.2024
Android — наблюдаемый список
Есть ли какой-либо наблюдаемый список в Android? ObservableList класс не существует! Я хочу иметь список, который, если произошли какие-либо изменения элемента, уведомит меня об обновлении представлений.
Примечание. Если нативного способа...
740 просмотров
schedule
22.12.2023
Каковы различия в реализации Schedulers.computation и Schedulers.io?
Почему они используются для разных видов задач? Что отличает их при обработке вычислительной задачи по сравнению с задачей ввода-вывода?
Schedulers.computation() — предназначен для вычислительной работы, такой как циклы событий и обработка...
674 просмотров
schedule
29.05.2024
Объедините несколько элементов из наблюдаемых в новые объекты с помощью RxJava
Я пытаюсь реализовать какой-то потоковый парсер. Допустим, у меня есть поток целых чисел, и я объединяю их, чтобы создать новый объект, который объединяет часть потока.
Например, объект считается «готовым», когда целое число отрицательно. Чтобы...
1557 просмотров
schedule
17.10.2023
