rx-java

0зной

1ответ

Как использовать наблюдаемые в onComplete (Rxjava2)

Я пишу свое приложение так сильно, как я могу из rxjava, и у меня возникает следующая проблема. У меня есть метод, который синхронизирует данные с api, и я загружаю материал на основе метки времени. П

3зной

1ответ

Выполнения последовательных вызовов API с Модернизированный и возвращение наблюдаемой

У меня есть сервис модифицированного, содержащего следующий интерфейс public interface ApiService { @GET("https://stackoverflow.com/users/me") Observable<Account> authenticateUser(@Header("

2зной

1ответ

Преобразование ListenableFuture цепь эквивалентной структуры RxJava

Использование Guava Listenable Futures Предположим у меня есть следующий класс: public class FooService { ListenableFuture<Foo> getFoo() { //code to create callable, then return liste

1зной

2ответ

Несколько вызовов API с использованием RxJava и Android

У меня есть список объектов, которые должны быть переданы в API последовательно и нуждаться в конечном обратном вызове, когда все вызовы завершены. Структура кода выглядит //Singleton class public cl

1зной

1ответ

ReactiveX собирает элементы, обработанные до сбоя

Я использую RxJava для создания фоновой работы, синхронизирующей мой db. Он подключается к внешнему источнику и начинает обрабатывать записи, отображать их и вставлять в db. Когда он заканчивается, мн