Я заметил, что если в doOnSuccess() выдается исключение, абонент не получит onSuccess(), а...

Я пытаюсь создать приложение MVVM Kotlin, которое использует Reactivex для выполнения асинхронных...

Я новичок в использовании ReactiveX, и мне предложили следующую проблему: import android.content.pm

У меня есть два сингла: выборка данных о пользователях из Facebook. выполнить регистрацию...

У меня есть фиктивный интерактор и маршрутизатор для модульных тестов по методике презентатора:...

Например, let observable1 = Observable<Void>.of([1, 2, 3, 4, 5, 6, 7]) .take(1) .flatMap{_ in...

У меня есть событие клавиатуры, которое вызывает воспроизведение анимации.Пользователь может...

У меня есть Flowable, который генерирует события, которые должны быть обработаны дорогостоящей...

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

У меня есть следующий код Disposable a = camRepo.getAttachmentToken(result.getResult().getId())

У меня есть функция в RxJava, которая пытается найти вещь на основе условия, и в случае успеха она...

В примере Javadoc Observable.retryWhen, AtomicInteger используется для counter вместо простого...

Я пытаюсь получить данные из JSON, используя модификацию и rx. Я следовал этому уроку . Но JSON из...

withLatestFrom не срабатывает при использовании с Observable.just(1), как показано ниже.Как будто...

Я немного новичок в RxJava.Я пытаюсь создать другой элемент, если onError () вызывается без потери...

Я действительно новичок в RxJS, и у меня есть вопрос относительно запроса RxJS ajax.Мне нужно...

Какие проблемы могут возникнуть при использовании переменных, которые являются внешними по...

В чем разница между: UpdateAsObservable() EveryUpdate() в UniRx? Являются ли онито же самое?

x - это поток.Для каждого события я генерирую поток x_i, который сам порождает события.Из этой...

Сегодня я переносил свой код из ReactiveSwift в RxSwift и пришел к этому странному сценарию. У меня...

Я хочу получать входные данные с помощью UniRx, а также инициировать некоторые события в...

У меня есть переменная, которая объявлена ​​как private lateinit var apiDisposable: Disposable , а...

"Сделать все действия, вызываемые в цепочках, вызываемыми в одном потоке. Многие, когда новая...

Я пытаюсь прочитать данные с конечной точки REST.После прочтения данных и я хочу построить список...

Я довольно новичок в RxJS и хочу сделать следующее: Представьте, что я пишу метод для отслеживания...