Я пытаюсь следовать шаблону проектирования MVP, используя RxJava2. Я новичок в этом. Поскольку я запрашиваю данные из API, в своем Presenter я вызываю свою модель следующим образом: mModel.getDataFromAPI() .subscribeOn(Schedulers.io())...

Я выдал два исключения в потоке и использовал onErrorReturn , чтобы перехватить эти исключения. Но я обнаружил, что было поймано только первое исключение. Как перехватить все исключения? Flowable.create(emitter -> { emitter.onError(new...

У меня есть служба, в которой я зарегистрировал обратный звонок, и теперь я хочу выставить его как Flowable с определенными требованиями / ограничениями: Обратный вызов получения потока не должен блокироваться (работа должна быть передана...

Как показано в следующем коде, я получаю сообщение об ошибке, связанное со следующей строкой, потому что приведение неверно. .subscribe((Consumer<? super List<String>>)getAnimalsObserver()); пожалуйста, дайте мне знать, как решить...