Вопросы по теме 'rx-java2'
RxJava 2.0 - обработка ресурсов для неперехваченной ошибки подписки в publish (). RefCount ()
Я новичок в RxJava и, как и многие другие, пытаюсь разобраться в обработке исключений. Я прочитал довольно много сообщений в Интернете (например, это обсуждение здесь как обрабатывать исключения, созданные наблюдателем onNext ) и думаю , что я...
149 просмотров
schedule
21.09.2022
Retrofit2+RxJava2, неверный токен, как обновить поток при повторной подписке retryWhen()
У меня есть этот простой код ниже, который имитирует сценарий, который я сейчас пытаюсь выполнить.
mApiService.api().postSomethingWithAccessToken(request, "some_invalid_access_token")
.subscribeOn(Schedulers.io())...
1516 просмотров
schedule
10.03.2024
Обработка длительных задач с помощью RxJava
Я пытаюсь перенести AsyncTask , который отправляет сообщения на сервер, для использования RxJava. Грубо говоря, задача состоит в следующем:
1) Создает сообщение, которое будет отправлено (сохраняется в базе данных) 2) Показывает сообщение...
876 просмотров
schedule
29.01.2024
Получение сигнала Fata 11 при попытке использовать Observable
Я работаю над проектом, впервые пробуя Kotlin, RxJava 2 и новые компоненты архитектуры Android. Я пытаюсь выполнить метод удаления из комнаты в отдельном потоке, и я получаю ERROR: Fatal signal 11 (SIGSEGV), code 1, fault addr 0x0 in tid 12673...
675 просмотров
schedule
16.03.2024
Обработка ответов Void и Non-Void с помощью Retrofit 2 и RxJava 2
У меня есть вызов для отправки данных на сервер. Если все в порядке, сервер возвращает пустой ответ. Но когда возникает ошибка, я получаю данные обратно.
Чтобы справиться с ошибкой, у меня есть объект CustomResponse . Проблема в том, что при...
685 просмотров
schedule
10.01.2024
Запрос по планированию потоков RxJava
Я новичок в RxJava2. В приведенном ниже коде я не могу понять, как подписчик работает в фоновом потоке, даже если Observable/Flowable испускается в основном потоке, а планировщик не указан (используя вызовы subscribeOn(Schedulers.*)). Полный код...
101 просмотров
schedule
23.01.2024
Перепишите Java-код в Kotlin, используя Справочник по функциям, возникает конфликт типов SAM
У меня есть пример кода Java, использующий ссылку на метод, который я хочу переписать на Kotlin. Версия Java использует ссылку на метод, решение краткое и ясное. Но с другой стороны, я не могу использовать ссылку на метод в Котлине. Единственная...
2614 просмотров
schedule
26.05.2024
Могу ли я использовать RxAndroidBle и RxJava2 в одном проекте?
У меня есть приложение для Android, основанное на RxAndroid (на основе RxJava2). Я также добавил зависимость RxAdnroidBle, которая по-прежнему использует RxJava1 .
Во время компиляции у меня была следующая ошибка:
Execution failed for task...
229 просмотров
schedule
26.11.2023
Запрос в Android всегда дает исключение тайм-аута сокета
Я пытаюсь сделать два запроса, когда пользователь нажимает кнопку. Однако запрос может занять некоторое время.
Когда пользователь находится в режиме экономии заряда батареи и экраны блокируют его устройство, пока запрос все еще выполняется, запрос...
673 просмотров
schedule
21.12.2023
Другой тип возврата в RxJava 2 (обновление с RxJava1)
Я переношу наше приложение с RxJava 1.x.x на RxJava 2.x.x. У меня проблема с одним из моих методов - он возвращает другой тип возвращаемого значения. У меня в версии 1.x.x был такой метод:
fun permissionsUsers(groupId: String):...
583 просмотров
schedule
08.02.2024
Как отписаться от вызова RXjava в широковещательном приемнике
Я использую RXJava2 для отправки электронной почты в широковещательном приемнике, и я хотел бы знать, когда я должен отказаться от подписки на событие. Код в основном:
getSmsMmsObservable()
.subscribeOn(Schedulers.io())...
1631 просмотров
schedule
02.01.2024
RxJava отличается выводом между Flowable и Observable с Window и Groupby
Я использую RxJava2 с кодом, который сводится к чему-то вроде этого:
val whitespaceRegex = Regex("\\s+")
val queryRegex = Regex("query=([^&]+)", RegexOption.IGNORE_CASE)
val dateTimeFormatter = DateTimeFormatter.ISO_OFFSET_DATE_TIME...
268 просмотров
schedule
30.11.2023
Фатальное исключение в планировщике - rxJava2 в Android
Я знакомлюсь с rxJava2 в Android с MVP.
Для начальных шагов я создал объекты Activity, Presenter и Model (каждый из них имеет класс интерфейса).
В своей деятельности я создаю презентатор и пытаюсь загрузить данные, уведомляя представление, когда...
713 просмотров
schedule
02.06.2024
Не удается заархивировать наблюдаемые объекты Rxjava
Я использую RxJava 2. *, и я хочу объединить результаты двух наблюдаемых (один из модификации, а другой из комнаты) с помощью оператора zip (не стесняйтесь предлагать лучше).
Объекты модели, поступающие с удаленного сервера, отличаются от объектов,...
516 просмотров
schedule
29.11.2023
RxJava 2 - Observable.flatMapSingle пояснение
Я провел эксперимент RxJava2 , состоящий из следующих шагов:
Создайте Observable из ListA объектов.
Используйте flatMapSingle () . для сопоставления каждого элемента, испускаемого Observable, с SingleSource. Внутри flatMapSingle ()...
7808 просмотров
schedule
02.11.2023
Как заставить RxJava2 Completable andThen() работать?
В моем приложении для Android я хочу обновить части записи базы данных (используя Room), а затем прочитать всю запись из базы данных, как только обновление будет завершено.
После прочтения документации RxJava Completable я ожидал public final...
1937 просмотров
schedule
27.11.2023
RXJava остановить, наблюдаемую внутри плоской карты
Я сделал приложение социального отчета с геотегами, чтобы сообщать о разбитых улицах на Android. Для публикации отчета требуются данные о местоположении. Либо из Exif фотографии, датчика GPS, либо установите его вручную из MapsPickerActivity.
Мне...
1310 просмотров
schedule
24.11.2023
RxJava2: 2 отдельных наблюдаемых вывода и объединенный вывод одних и тех же наблюдаемых различаются
Snippet1 , я вижу sysout от обоих подписчиков. Snippet2 , я не вижу вывода от второго наблюдаемого. Почему у меня не работает слияние?
Фрагмент1
x = createQ2Flowable().subscribeOn(Schedulers.computation())
.observeOn(Schedulers.io())...
85 просмотров
schedule
18.10.2022
Как сортировать значения в Observable?
Допустим, у меня есть Observable, а у Player есть следующие поля (среди прочего):
enum Height, enum Status, enum Name
И я хочу вернуть Единственного лучшего игрока из этого Observable (оно не пустое): у которого есть либо height =...
368 просмотров
schedule
15.06.2024
Извлечь каждый элемент из списка массивов в RxJava
Как я могу заставить каждого пользователя из Observable<ArrayList<user>> обрабатывать некоторые другие наблюдаемые объекты, прежде чем подписчик подпишется на него. Я искал его в переполнении стека и узнал о flatMapIterable() , но все...
149 просмотров
schedule
17.12.2023
