寻找一种干净的方法处理RxJava中的错误

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 执行一些操作，可能会抛出异常
        try {
            // 执行操作
            emitter.onNext("Data");
            emitter.onComplete();
        } catch (Exception e) {
            // 发生错误时，调用onError方法
            emitter.onError(e);
        }
    }
})
.onErrorResumeNext(new Function<Throwable, ObservableSource<? extends String>>() {
    @Override
    public ObservableSource<? extends String> apply(Throwable throwable) throws Exception {
        // 处理错误，并返回备用的Observable
        return Observable.just("Error occurred: " + throwable.getMessage());
    }
})
.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(String s) {
        // 接收到数据时的操作
        System.out.println(s);
    }

    @Override
    public void onError(Throwable e) {
        // 发生错误时的操作
        System.out.println("Error: " + e.getMessage());
    }

    @Override
    public void onComplete() {
        // 完成时的操作
    }
});