Вопросы по теме 'rx-java'
Observer.onError срабатывает непоследовательно
Я использую Retrofit для доступа к моему API следующим образом:
public interface UserService {
...
@POST("/user/login")
public Observable<User> register(@Body() User user);
}
Вот как я получаю доступ к своему API:...
5549 просмотров
schedule
24.11.2022
Retrofit/Rxjava и сервисы на основе сеансов
Я реализую сервисы на основе сеансов. Все запросы должны быть подписаны с параметром сеанса cookie, который, в свою очередь, извлекается с помощью отдельного API-интерфейса. Таким образом, основной рабочий процесс будет состоять в том, чтобы...
5080 просмотров
schedule
18.04.2024
Наблюдаемые цепочки RxJava и обработка ошибок (распространение пользовательских исключений)
У меня есть 5 Observable , которые связаны с flatMap . В случае, если первые четыре Observable производят Exception , я хочу распространить другой тип Exception на пятый.
Как это достигается?
Спасибо.
P.S. Я придумал это еще...
12115 просмотров
schedule
26.10.2022
Потребление значений, одновременно испускаемых наблюдателем
Я изучаю реактивное программирование с помощью RxJava и хочу одновременно использовать переданные значения без блокировки в одном потоке выполнения.
Observable
.interval(50, TimeUnit.MILLISECONDS)
.take(5)...
495 просмотров
schedule
01.12.2023
RxAndroid: синхронно выполнять наблюдаемое
Я начинаю с Rx с RxAndroid и хочу указать имя пользователя GitHub по его API с помощью Retrofit. Каждый запрос API приносит 100 пользователей, после того, как я обработал всех пользователей, я хочу получить следующие 100, но я не понимаю, как это...
2773 просмотров
schedule
03.03.2024
RxJava: как эмулировать с помощью LatestFrom?
Согласно документации, withLatestFrom отсутствует в реализации Java (что немного отличается от combineLatest ). Любая идея о том, как подражать этому?
2381 просмотров
schedule
28.11.2023
rxjava добавить элементы после создания наблюдаемого
Я только начал использовать rxjava и застрял. Возможно, я неправильно использую rxjava, но мне нужно добавить элементы в Observable после его создания. Итак, я понимаю, что можно просто позвонить Observable.just("Some", "Items") и подписчики их...
11811 просмотров
schedule
27.11.2022
RxJava android не работает и не может скомпилировать код
Я хочу изучить RXjava для Android, поэтому я сделал следующее:
1) Я скачал jar-файл rxandroid-0.24.jar, rxandroid-framework-0.24.jar 2) добавил файлы в папку libs в студии Android 3) добавил зависимость lib в студию Android, пожалуйста, проверьте...
2259 просмотров
schedule
09.02.2024
Очередь независимых наблюдаемых
Можно ли поставить в очередь несколько наблюдаемых, чтобы они выполнялись друг за другом, не зная друг друга?
Допустим, у меня есть 3 разных Observables в 3 разных классах и/или потоках. Все они представляют разные запросы. Порядок их выполнения...
67 просмотров
schedule
26.10.2023
Разница между потоками Java 8 и наблюдаемыми объектами RxJava
Сходны ли потоки Java 8 с наблюдаемыми объектами RxJava?
Определение потока Java 8:
Классы в новом пакете java.util.stream предоставляют Stream API для поддержки операций функционального стиля с потоками элементов.
46731 просмотров
schedule
24.12.2023
Количество выполнений flatMap зависит от наблюдателя, в то время как требуется одиночное
У меня есть механизм push-уведомлений (PublishSubject), который запускает логику HTTP-запроса (flatMap). Базовый сценарий заключается в том, что всякий раз, когда приходит push, выполняется один HTTP-вызов, и результаты распространяются на несколько...
180 просмотров
schedule
14.01.2024
RxJava, в чем разница между запуском и созданием?
Я смотрю на этих двух операторов, которые, похоже, выполняют одну и ту же работу:
http://reactivex.io/documentation/operators/start.html http://reactivex.io/documentation/operators/create.html
Создать только новую версию запуска? Потому что...
176 просмотров
schedule
11.11.2022
RxJava Timer Observable, но дождитесь завершения
У меня есть что-то вроде этого:
return Observable.timer(2, TimeUnit.SECONDS)
.flatMap(integer -> captureList.getLatestCaptureCut()) #1
.flatMap(vp::processVideo) #2...
1451 просмотров
schedule
19.09.2022
Необходим ли SerializedSubject для потокобезопасности в RxJava?
Я создал экземпляр Subject в RxJava и вызываю его onNext() из нескольких потоков:
PublishSubject<String> subject = PublishSubject.create();
//...
subject.onNext("A"); //thread A
subject.onNext("B"); //thread B
В документации...
3627 просмотров
schedule
02.05.2024
Как заставить flatMap выполняться в фоновом потоке
Я использую Retrofit и RxJava для выполнения некоторых фоновых задач. Код выглядит так:
public class MyLoader{
public Observable<MyData> getMyData(){
return setupHelper().flatMap(new Func1<MyHelper,...
6332 просмотров
schedule
07.05.2024
RxJava — кэш () — это то же самое, что и повтор ()?
Мне было интересно, есть ли оператор cache() , который может кэшировать x количество выбросов, но также истечать их через определенный интервал времени (например, 1 минуту). Я искал что-то вроде...
Observable<ImmutableList<MyType>>...
9970 просмотров
schedule
01.12.2023
RxJava отказывается от одного наблюдателя от другого
Предполагая следующий сценарий, что было бы лучшим/рекомендуемым решением проблемы?
У меня есть два потока, один из которых представляет TCP-соединение, а другой представляет состояние этого TCP-соединения. Как только статус изменится (т.е....
135 просмотров
schedule
29.02.2024
Цепочка вызовов модификации с RxJava
Итак, в основном, что я пытаюсь сделать, это сделать первый сетевой вызов. И если вызываемая веб-служба RESTful возвращает 1, сделайте второй сетевой вызов. Если веб-служба возвращает 0, второй сетевой вызов не выполняется.
Вот мой код
final...
310 просмотров
schedule
08.12.2022
RxJava: обновить результат вызова результатами последующих вызовов
У меня есть 2 вызова:
getItems() - возвращает List<Item> , также Item имеет поле id
getParam(id) - возвращает Param
Мне нужно сделать getItems() , а затем getParam(id) для каждого Item в List , а затем нужно обновить...
132 просмотров
schedule
28.10.2022
Усечение FlatMapIterable
Я хочу сопоставить список элементов с наблюдаемыми, а затем каждую плоскую карту наблюдаемых элементов с другой функцией для ее обработки, чтобы сохранить результаты некоторого вызова REST API в базе данных.
Вызов API правильно возвращает все...
3078 просмотров
schedule
08.12.2023
