Вопросы по теме 'rx-java2'
RxJava: как выразить doOnFirst()?
Я использую RxJava, и у меня есть Observable с несколькими элементами внутри. Что я хотел бы сделать, так это запустить функцию A для первого элемента, функцию B для всех из них и функцию C, когда Observable завершено:...
1377 просмотров
schedule
08.09.2022
Android RxJava2: как настроить правильный асинхронный наблюдаемый, использующий REST API?
Мой код:
RestClient client = new RestClient();
Disposable subscribe = client.getApiMovie().getTopRated()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())...
768 просмотров
schedule
23.06.2023
Повторный запрос и обновление подписчиков с помощью RxJava2
У меня есть уровень данных в моем приложении, который поддерживается службой модернизации. (Пока есть только постоянство по сети. Когда я продвинусь дальше, я добавлю автономное локальное хранилище)
Retrofit возвращает мне...
938 просмотров
schedule
20.11.2022
Как я могу сгруппировать события, испускаемые полем?
У меня есть пользователь класса:
class User {
String companyId;
}
и класс Компания:
class Company {
String id;
List<User> users;
}
Мне нужно «сгруппировать» пользователей, созданных Observable<User> компанией,...
57 просмотров
schedule
22.03.2023
404 - при вызове API с Retrofit2 и RXJava2
У меня проблема с вызовом API с указанными ниже библиотеками.
Мои зависимости:
compile 'com.squareup.retrofit2:retrofit:2.1.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'
compile...
4650 просмотров
schedule
10.07.2022
Picasso + RxJava2: вызов метода должен происходить из основного потока
Это был мой первоначальный вопрос:
Я пытаюсь показать несколько изображений в файле AutoScrollViewPager . Я использую Picasso для достижения того же. Однако я хотел бы сделать то же самое с использованием Rxjava2 + Picasso. Я новичок в этой...
3269 просмотров
schedule
31.08.2022
Выполнение последовательных вызовов API с помощью Retrofit и возвращение наблюдаемого
У меня есть служба модернизации, которая содержит следующий интерфейс
public interface ApiService {
@GET("/users/me")
Observable<Account> authenticateUser(@Header("Authorization") String auth);
@GET("/membership/{userId}")...
942 просмотров
schedule
26.05.2023
Прочитайте файл асинхронно с RxJava 2
Я пытаюсь создать Observable<ByteBuffer> или Flowable<ByteBuffer> , которые будут читать файл асинхронно (или, по крайней мере, я ищу лучшую производительность, которую Java может дать мне в этом случае использования - чтение файла)....
1240 просмотров
schedule
30.03.2023
Тест RxJava JUnit с Retrofit вызывает исключение NullPointerException
У меня есть вызов API retrofit2
public interface FeedService {
@GET("/api/v1/feeds")
Observable<FeedResponse> getFeeds(@Query("page") Integer pageNumber,
@Query("cats") String categories,...
1344 просмотров
schedule
25.02.2023
Как адаптировать многопоточную скорость вычислений наблюдателя к холодному Observable‹List‹T››
У меня есть Источник как холодный Observable<List<T>> который эмитирует элементы чанками (списками), я хочу каждый отдельный элемент из чанка обработать в отдельном потоке, пока эмиттер (источник) ждет окончания обработки всех элементов...
78 просмотров
schedule
12.08.2022
Опрос с использованием RXJava2/RXAndroid 2 и Retrofit
Я хотел бы реализовать службу опроса, которая вызывает API REST каждые nDelay Seconds и уведомляет всех подписчиков, если данные были изменены. Теперь у меня есть небольшая проблема с моим кодом, поскольку он всегда возвращает значение моему...
707 просмотров
schedule
25.08.2023
RxJava2 передает данные через flatMap на Single
В rxjava 1 у Observable был этот метод плоской карты
общедоступная конечная наблюдаемая плоская карта (Func1 collectionSelector, Func2 resultSelector)
Это позволило вам передать / объединить исходный результат подписчику на плоскую карту....
4563 просмотров
schedule
23.03.2022
В чем разница между Observable, Completable и Single в RxJava
Может ли кто-нибудь объяснить разницу между Observable, Completable и Single в RxJava с четкими примерами?
В каком сценарии мы используем одно по сравнению с другим?
30533 просмотров
schedule
13.05.2023
Сгруппировать список событий в словарь событий по дате
Я пытался изучить RxJava2, и я боролся с этим.
Итак, у меня есть структура, представляющая события, которые выглядят примерно так:
class Event{
public Date when;
public String eventName;
}
И где-то я запрашиваю список событий из...
243 просмотров
schedule
26.08.2023
Android - с использованием привязки данных, в действии вместо макета
Я работаю в шаблоне проектирования MVVM. Я хочу использовать dataBinding или RXJava, чтобы уведомлять представление об изменении модели. dataBinding может сделать это внутри xml . но я хочу уведомить Activity об изменении модели и сделать что-то...
1782 просмотров
schedule
12.03.2024
Порядок последовательности RxJava2, вызываемый с помощью дополняемого оператора andThen
Я пытаюсь перейти с RxJava1 на RxJava2. Я заменяю все части кода, где раньше было Observable<Void> , на Compleatable . Однако я столкнулся с одной проблемой с порядком потоковых вызовов. Когда я раньше имел дело с Observables и использовал...
617 просмотров
schedule
26.11.2023
Параллельное создание объектов с помощью RxJava
Я написал микросервис Spring Boot, используя RxJava (агрегированный сервис) для реализации следующего упрощенного варианта использования. В целом, когда преподаватель загружает документ с содержанием курса, необходимо создать и сохранить набор...
208 просмотров
schedule
22.01.2023
Как правильно контролировать выбросы для определенного планировщика в созданном Observable
Я использую RxJava2 и, допустим, у меня есть этот Observable:
Observable
.create(emitter ->
SomeDependency.registerCallback(data -> emitter.onNext(data))
)
.subscribeOn(Schedulers.io());
Он наблюдает за некоторой...
208 просмотров
schedule
17.08.2022
UndeliverableException при вызове onError ObservableEmitter в RXjava2
У меня есть метод, который создает эмиттер, как показано ниже, есть проблема (возможно, это нормальное поведение) с вызовом onError в обратном вызове модификации. Я получил UndeliverableException при попытке вызвать onError.
Я могу решить эту...
6459 просмотров
schedule
19.07.2023
создать один поток списка наблюдаемых Rxjava 2
У меня есть список идентификаторов и метод, который принимает идентификатор и возвращает Observable<Boolean> , он выполняет операцию с использованием идентификатора и возвращает true в случае успеха.
скажем, у меня есть идентификатор...
580 просмотров
schedule
26.06.2022
