Я использую rxAndroid и rxKotlin в своем приложении для Android для асинхронной обработки сетевых запросов. Теперь я хотел бы повторить неудачный сетевой запрос только после нажатия кнопки Snackbar. Мой код сейчас: val citiesService =...

Я думал, что это так работает, кажется, я что-то упускаю.. @Test fun singleCompletes() { val testSubscriber = TestSubscriber<Boolean>() Single.just(true) .subscribeOn(Schedulers.immediate()) .subscribe {...

Я пытаюсь протестировать следующий код RxKotlin/RxJava 2: validate(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { ... } Я пытаюсь переопределить планировщики следующим образом: //...

Я пишу следующий фрагмент кода, чтобы получить список сохраненных продуктов из базы данных Firebase, а затем, используя этот список, я снова извлекаю отдельные сведения о продуктах из базы данных Firebase. Следующий код работает нормально, за...

У меня есть поток ResponseMessage , который может быть разных подтипов. Я хотел бы разделить поток на потоки, где я могу обрабатывать каждый тип в своем собственном потоке. Моя первая попытка привела к этому, чего я не вижу. file.readLines()...

Извините, нуби-котлин, вопрос func someThingElse(): Observable<String> { return Observable.just("aasd") } fun doSomething(): Observable<Void> { return someThisElse().fetch().map { () } } Как вернуть наблюдаемую пустоту?...

У меня есть объект, который генерирует разные строки в случайные моменты времени, и мне нужно подключиться к этому генератору, чтобы взять эти строки и предоставить их пользовательскому интерфейсу (возможно, это будет несколько подписчиков в разных...

Я осознаю: io.reactivex.exceptions.OnErrorNotImplementedException: исключение не было обработано из-за отсутствия обработчика onError в вызове метода subscribe () Я пытался добавить .doOnError { error -> Log.i("reverser...