Я изучаю реактивное программирование и хотел бы реализовать реактивную конечную точку (с...
Это первый раз, когда я использую RxJava (а также Android Room, хотя и не относящийся к проблеме).Я...
У меня есть список идентификаторов, и я сопоставляю его со списком подсписков, поэтому получаю...
Я работаю с Reactive X на Android. Когда я вызываю эту наблюдаемую: fun getTalks() :...
Любая помощь приветствуется !!!В первый раз, когда пользователь приходит на экран, он проверяет,...
Возможно, это вопрос rx newbee. Если у меня есть два потока rx, которые имеют некоторые общие части...
Я впервые работаю с Room и RxJava.Я получаю очень противоречивые результаты, когда читаю из БД.У...
fun remove(data: String): Single<JSONApiObject> { return service.remove(data)
Flowable.just(getSize()) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread())
Вот как выглядит мой поток: cameraStateObservable .switchMap(cameraStateEvent -> { if...
Мой вопрос довольно прост (я просто развлекательный кодер, играющий с вещами).Я установил...
просто спрашиваю, правильно ли я делаю, потому что я не знаю, почему doOnComplete звонит, а...
У меня есть SplashActivity, который должен вести себя по-разному в зависимости от состояния входа...
В rx-java 2.x есть оператор с именем throttleLatest , который объединяет входящие события на основе...
Я объявил: Subject<String> mBehaviorSubject = BehaviorSubject
Я пытаюсь написать функцию расширения для Observable.subscribe, которая автоматически регистрирует...
У меня есть фиктивный сетевой источник данных: fun networkDataSource():...
Мой вопрос похож на этот RXJS: Одиночная наблюдаемая из динамически создаваемых наблюдаемых (ответа...
У меня есть эти два Observable в Котлине, где он просто действует как таймер, а другой - ответ...
У меня есть операция с задержкой: mySingle.delaySubscription(60, TimeUnit.SECONDS).subscribe();...
Мы уже знаем, что Observable может иметь только один аргумент в качестве универсального типа
Android Studio 3.3 RxJava 2 У меня проблемы с пониманием явного возврата лямбды. Например, я...
В настоящее время мы обновляем наше приложение для Android с RX1 до RX2.Однако некоторые тесты...
Я только что написал некоторый пример кода с помощью takeUntil - final Observable<Integer>...
class Entry(var amount: Double,var name:String): Parcelable{ @PrimaryKey(autoGenerate = true)...