Я пытаюсь использовать RxJava2 в моем текущем проекте Android. implementation 'io.reactivex

Допустим, у меня есть источник данных, генерирующий события, который я хочу преобразовать в...

Например, у меня есть следующий код, который использует библиотеку RxJava: public class...

У меня есть две услуги: private Observable<UMapsResponse> requestToServiceGetMaps(int idVenue...

Я интегрировал RxJava2 с Retrofit2 и не могу получить журналы для вызовов API с помощью...

Я хочу сделать два параллельных запроса к базе данных Realm и вернуть результаты с помощью RxJava

Я пытаюсь преобразовать Flowable<List<TaskEntity>> в Flowable<List<Task>>,...

Используя RXJava 2, я пытаюсь создать асинхронную шину событий. У меня есть одноэлементный объект...

Я знаю, ребята. Нулевого указателя было уже много. Честно говоря, я прочитал все эти темы, но не...

Я получаю ответ API и создаю List<Logs>. Этот список включает в себя еще один список...

Как объединить несколько результатов, излучаемых наблюдаемыми, в один результат и выдать его один...

У меня есть код ниже в моей активности Android, который работает как задумано. при событиях...

Прочитав несколько постов в блоге и документацию, я пришел к выводу, что в рабочем потоке будет...

Я использую RxJava 2 для вызовов API. Мне нужно позвонить, чтобы отменить бронирование класса. Но...

Я пользуюсь Play Services Auth api Phone и пока у меня есть следующие fun startSmsListener() { val...

У меня есть следующая цепочка Rx: compositeDisposable.add(manager.getObservable() .map(objects...

Мой вопрос о методе toBlockingFirst(). Это надежный метод?т.е. могу ли я получить...

У меня есть следующий минимальный (не) рабочий пример: import org.junit.Test; import io.reactivex

У меня есть API, который возвращает Single.Это Single содержит список значений, скажем, String...