Вопросы по теме 'rx-android'
Как абстрагироваться от оборудования с помощью RXJava и Observables без субъектов?
Я работаю над проектом, в котором у меня есть аппаратное устройство, разговаривающее с моим Android-приложением через USB-кабель. Буферы протокола, завернутые в тонкий слой сериализации, — это мой протокол связи.
В настоящее время связь USB...
347 просмотров
schedule
19.01.2024
Минимальное время выполнения Rxjava?
У меня есть Observable A и Observable B. Теперь мне нужно дождаться завершения этих Observables или хотя бы 30 секунд. Как я могу добиться этого на RxJava?
Спасибо за любое предложение!
1095 просмотров
schedule
18.09.2022
RxJava onErrorResumeNext вызывает java.io.InterrupedIOException
У меня проблема с оператором RxJava onErrorResumeNext. Я хочу получить местоположение, а затем получить данные с сервера (с доработкой) зависит от местоположения, но если нет местоположения (ошибка: последовательность не содержит элементов), я хочу...
737 просмотров
schedule
17.11.2022
RxAndroid — java.lang.IllegalStateException: уже зарегистрирована другая стратегия
Я пишу модульный тест, и мне нужно смоделировать Observable (из модификации)
Код в тестируемом компоненте выглядит следующим образом:
getApiRequestObservable()
.observeOn(AndroidSchedulers.mainThread())...
1387 просмотров
schedule
04.02.2024
Как создать наблюдаемую JavaRx, которая выдает синхронный (или блокирующий) список всем подписчикам?
Я очень новичок в RxJava, Android и Java вообще... Я пытаюсь создать наблюдаемый объект, который генерирует синхронизированный список. Где я не прав?
public class CurrentLocationHolder {
private List<LocationPoint> locationBuffer =...
101 просмотров
schedule
03.11.2022
Правильный способ фильтрации элементов базы данных с помощью RxAndroid
Я использую предоставленный образец и настроил код в соответствии со своими требованиями. Я изучаю Rx и не совсем знаком с тем, как он работает. Итак, в моем фрагменте у меня есть
private static String LIST_QUERY = "SELECT * FROM " +...
373 просмотров
schedule
12.08.2022
Почему debounce() с toList() не работает в RxAndroid?
Пока я использую debounce() , затем извлекаю данные из бэкэнда и данные, которые я хочу преобразовать в другие данные, и, наконец, использую toList() . когда я использую toList() ничего не происходит никакого лога нет в подписке и ошибка, без...
478 просмотров
schedule
25.01.2024
Как повторно использовать Observer в случае сбоя?
У меня есть действие, которое загружает данные из сети и имеет кнопку «повторить попытку», если запрос не выполняется, который просто повторяет тот же сетевой вызов. Это упрощенный код:
public class MainActivity extends Activity {
private...
535 просмотров
schedule
24.08.2022
Предотвратить эмиссию, если такая же эмиссия произошла x миллисекунд назад
Я хотел бы предотвратить выброс тогда и только тогда, когда один и тот же точный элемент был испущен в течение последних x миллисекунд. Я посмотрел на операторов дроссельной заслонки и устранения дребезга, но я не уверен, что они могут мне помочь...
262 просмотров
schedule
14.11.2023
Как сделать Observable, который испускает символ через 1 секунду временного интервала
Я только начал с RxJava/android, и для практики и начала работы я хочу сделать наблюдаемым, который испускает символ в строке каждую 1 секунду, как я могу это сделать? Вот что я пробовал до сих пор, он просто выдает строку сразу:...
1482 просмотров
schedule
19.03.2024
Google Agera против rxAndroid
Когда я впервые приступил к реактивному программированию для Android, я обнаружил rxJava и rxAndroid , которые предпочитают многие разработчики в мире. Но сегодня я нашел другую библиотеку Google под названием Agera , которая все еще находится в...
920 просмотров
schedule
06.04.2024
как использовать retryWhen () Rxandroid
Я вызываю дорогостоящую рекурсивную функцию с помощью RXJava. В большинстве случаев он работает очень быстро, но иногда занимает слишком много времени.
Есть ли способ использовать retryWhen() через 5 секунд, если поток все еще работает?...
248 просмотров
schedule
03.10.2022
Повторно выполнить наблюдаемое, чтобы уведомить в настоящее время подписанных наблюдателей
В сценарии приложения для Android я хочу получить некоторые Observable<Data> из сети, и на них подписано несколько Observer<Data> для обновления соответствующих представлений. В случае ошибки - скажем, тайм-аут - покажите пользователю...
520 просмотров
schedule
29.12.2023
RxJava — перехват потребительского исключения
В настоящее время я пытаюсь найти лучшее решение для моей сетевой обработки в моем приложении для Android. В настоящее время я использую RxJava и несколько классов Consumer .
Потребитель
public interface Consumer<T> {
/**
*...
2082 просмотров
schedule
03.11.2022
RxJava/Retrofit2/Java — NetworkBoundResource не работает должным образом
У меня проблема с проводкой. Когда я впервые подписываюсь, он делает сетевой вызов, а также сохраняет данные в базу данных, но loadFromDb() никогда не выполняется, и он не выдает никаких ошибок.
Почему это происходит?...
710 просмотров
schedule
28.03.2024
RxJava выполняет Completable после Single асинхронно
Есть ли способ позволить Single генерировать данные и когда они (или, может быть, когда они завершатся) запускать Completable с этими данными асинхронным способом?
Мой вопрос очень похож на этот , но я пытаюсь вызвать Completable асинхронно....
132 просмотров
schedule
25.04.2024
RxAndroid аварийно завершает работу при использовании AndroidScheduler.mainThread()
Я использовал RxJava и RxAndroid для извлечения данных из API и обновления своего представления. Но после использования RxAndroid AndroidScheduler.mainThread() приложение вылетает с неизвестными исключениями.
Также я использую RxJava и RxAndroid...
115 просмотров
schedule
10.10.2023
