Android RxJava2 -抛出错误如何进行接口调用？

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 执行接口调用
        try {
            // 调用接口
            String result = apiCall();
            emitter.onNext(result);
            emitter.onComplete();
        } catch (Exception e) {
            // 发生错误时，将错误传递给观察者
            emitter.onError(e);
        }
    }
})
.onErrorResumeNext(new Function<Throwable, ObservableSource<? extends String>>() {
    @Override
    public ObservableSource<? extends String> apply(Throwable throwable) throws Exception {
        // 错误处理逻辑
        // 返回一个新的Observable，继续进行接口调用或者返回默认值
        return Observable.just("默认值");
    }
})
.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(String result) {
        // 成功返回结果时的操作
    }

    @Override
    public void onError(Throwable e) {
        // 错误处理逻辑
    }

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