Articles of наблюдаемое

Переключающие наблюдения

У меня есть два наблюдаемых ob1 и ob2 . Теперь мне нужно переключиться между ob1 и ob2 на основе условия, что я должен переключиться на ob2 когда ob1 не испускает и переключается обратно на ob1 когда он начинает излучать.

Подождите завершения задач подписчиков ConnectableObservable

Я создал наблюдаемый, который будет использоваться несколькими подписчиками, что делает некоторые ресурсоемкие задачи с испусканием. Используя следующее: val connectableObservable = Observable.create {…}.publish() connectableObservable.doOnNext {…}.subscribe() connectableObservable.doOnNext {…}.subscribe() connectableObservable.connect() К сожалению, connect () только синхронно ждет источника, который не для подписчиков, для выполнения задач. Есть ли способ подождать, пока подписчики ConnectableObservable завершат задачи и только потом продолжу […]

Создайте текущую функцию генерации с помощью RxJava2

Мне нужно создать настраиваемый Flowable с противодавлением. Я пытаюсь добиться своего рода подкачки. Это означает, что когда нисходящий поток запрашивает 5 элементов, я «спрошу источник данных» для пунктов 0 – 5. Затем, когда нисходящий поток нуждается в еще 5, я получу пункты 5 – 10 и вернусь обратно. Самое лучшее, что я нашел до сих […]

Дополнительные наблюдаемые данные в combLatest

Как определено, combLatest в rx emites только если все значения изменились хотя бы один раз. (до тех пор, пока каждая из исходных наблюдателей испускает хотя бы один элемент) Я использую его для манипулирования представлениями в своих представлениях Android. Например, я включаю кнопку вызова к действию, как только все наблюдаемые выдают действительное значение. В противном случае […]

Сочетание результатов нескольких наблюдаемых

Я пытаюсь добиться чего-то вроде этого: – Сделайте два разных вызова API и объедините результаты в список. Результат для каждого вызова – это HashMap, и у меня есть функция, чтобы преобразовать его в список. Сейчас я пытаюсь объединить списки в один, но у меня возникают трудности. Это то, что выглядит моя служба Retrofit: @GET("data/price?fsym=ETH") fun […]

RxJava Значение по умолчанию для throttleFirst

Как предоставить значение по умолчанию для throttleFirst когда наблюдаемый источник не испускает ничего в заданный промежуток времени? ob1.throttleFirst(1, TimeUnit.SECONDS) Я попытался defaultIfEmpty() но я, похоже, не работаю.

Intereting Posts
Как создать пустой конструктор для класса данных в Kotlin Android Получить строку базы данных с помощью Anko Сравнение списков сопоставимых данных в Котлине Как назначить байт в котлин? Не удалось синхронизировать Gradle: не удалось GET 'https://jcenter.bintray.com/org/jetbrains/kotlin/kotlin-gradle-plugin/1.1.3-2/kotlin-gradle-plugin-1.1.3-2.pom' Как получить статус доставки сообщения с помощью smack? Является ли я единственным автоответчиком IDEA, который не работает в Котлине? Плавная прокрутка в JavaFX TableView Ошибка сборки Kotlin kapt, gradle и ebean Запустите AutoBackup вручную из приложения Android. Вложенные аннотации в Котлине Kotlin генерирует конструктор, который устанавливает значения по умолчанию для нулевых аргументов Как правильно реализовать lateinit с пользовательскими объектами класса для использования в onCreate () в android, избегая ошибки Property getter или setter expected Kotlin – видимость атрибута для сопутствующего объекта Как я могу называть класс java как A: extends B реализует C в kotlin