Рассмотрим сценарий, в котором у нас есть поток, генерирующий строки, и мы хотим сохранить строки в...
У меня действительно сложная проблема. У меня есть метод void insert(User user) в моем DAO.Я...
Я пытался выполнить задачу, используя RxJava.В основном, есть четыре наблюдаемые.Я понял, как...
У меня есть следующий код для включения режима погружения. Это повторяющаяся задача, которая...
Я использую RxJava в своем проекте Android, и я рад этому. В настоящее время я использую его для...
У меня есть список «пользовательских» сущностей, я могу вставить всех пользователей с помощью:...
Мне нужно сжать более 3 наблюдаемых с помощью оператора zip в rxkotlin, но когда я пытаюсь сжать...
Я недавно столкнулся с вопросом об использовании Subject, как здесь: https://github
Я создаю этот PublishProcessor, который каждые 10 секунд сохраняет в базе данных свой элемент: val...
При публикации на PublishSubject в моей программе генерируется только первый опубликованный объект
Я использую оператор .debounce в rxjava / rxscala для захвата некоторых событий, которые происходят...
Рассмотрим следующий код: Collection<String> foos = Arrays.asList("1",...
Я хочу спросить о моем коде. Ошибка не отображается, когда я вставляю данные в базу данных, но...
Я работаю над регистрацией приложений для Android, в которой мне нужно выполнить несколько задач,...
Я хочу обработать исключение, выпустив 2 элемента. Я хотел бы иметь что-то вроде...
Требуется ли соблюдение части в этом случае, или для правильной обработки достаточно указать...
Я хочу реализовать довольно простую группу обеспечения доступности баз данных в RxJava. У нас есть...
Я создал автономный веб-просмотр в приложении для Android, чтобы вычистить URL-адрес с веб-страницы
У меня есть список значений, и я собираюсь напечатать каждый его элемент с помощью Rxjava2. Если...
Я вставляю только 1000 объектов в базу данных комнат с помощью Rx-Android, но это занимает не менее...
Когда я создаю 5 наблюдаемых и подписываюсь на каждую из них с отдельным подписчиком, я интуитивно...
У меня есть следующие методы для запроса и ответа: data class ApiRequest(...
У меня есть база данных в памяти для тестирования. Я хочу вызвать вставку несколько раз. Мой DAO...
Я написал программу, которая получает сообщения от сокета io, а затем воспроизводит медиа-файл
Ниже приведен мой код для добавления наблюдаемых в составные одноразовые compositeDisposable