Я прочитал некоторые проблемы RxJava2 о сбое после вызова dispose() в Observable здесь и здесь ....
Итак, в моем проекте Android я использую RxJava в слое хранилища, а затем преобразовываю его в...
Я использую Rx на Android в редактируемом текстовом поле. Я хочу получить исходный пользовательский...
Я хочу отфильтровать, когда во время выполнения какой-либо функции верхней цепочки возникает...
У меня есть наблюдаемое: Observable.create<Boolean> {emitter = it}, к которому я добавляю...
У меня есть следующий пример: private var dis: Disposable? = null override fun...
private fun getAllFollowers(user: User){ val items = user.items val requests =...
Я пытаюсь создать приложение с использованием RX Java, которое должно прослушивать брокер сообщений
Я собираюсь реализовать механизм пакетной обработки перед публикацией API для простого сбора и...
Я хочу создать наблюдаемое, которое будет испускать элементы только тогда, когда подписчики его...
Я знаю операторы delay() и repeat() и прочитал этот вопрос . Однако я хочу, чтобы первое событие...
У меня есть запрос к комнате DB: @Query("SELECT SUM(count*amount) FROM basket_items")...
У меня следующий код sealed class AddressUiState object AddressLoading : AddressUiState() class...
Я хочу вызвать два параллельных вызова службы и заполнить ответ в другой объект для дальнейшей...
Я хочу получить список мест с расстоянием и добавить это расстояние, только если доступно последнее...
Я вызываю один веб-сервис, использующий `RxJava2 'в android native следующим образом.Проблема...
Я пытаюсь использовать RxJava с Android для асинхронного обновления моего представления.Когда...
У меня есть простой список моего POJO под названием Sport, в котором есть поле имени. Каков...
@Entity(tableName = "items") class Item { @PrimaryKey var id=0 @ColumnInfo(name =...
У меня есть один проект Android, который я разработал в архитектуре Kotlin + MVP .Он имеет в общей...
Пожалуйста, посмотрите на этот код: Основная деятельность: @Override protected void onCreate(Bundle...
У меня есть метод getPlaces в моем хранилище: override fun getPlaces(filter: FilterRequest):...
Я хочу сделать два вызова, один для списка репозиториев github, второй для коммитов на каждом репо...
В следующем методе, как передать результат первого сингла во второй сингл? Как написано сейчас,...
Я пытаюсь заархивировать List<Flowable>, используя RxJava2, но он не скомпилируется.Фрагмент...