将带有该cat抛出的代码转换为Rxjava

鉴于您的方法具有as return类型void,我建议您使用 Completable .

您可以使用RxJava 2尝试此解决方案

Completable myCompletable = Completable.fromAction(new Action() {
        @Override
        public void run() throws Exception {
            launch();
        }
    }).retry(3 /*number of times to retry*/, new Predicate<Throwable>() {
        @Override
        public boolean test(Throwable throwable) throws Exception {
            return throwable instanceof MyException;
        }
    });

然后订阅Completable

myCompletable.subscribeOn(SubscribeScheduler)
             .observeOn(ObserveScheduler)
             .subscribe(this::onComplete, this::onError);

希望这有帮助。