Rx如何根据错误类型返回Throwable或Object

Observable.create(emitter -> {
    try {
        // 执行一些操作
        // 如果发生错误，抛出Exception或RuntimeException
    } catch (Exception e) {
        emitter.onError(e);
    }
})
.subscribe(
    // 处理正常结果
    result -> { /* 处理结果 */ },
    // 处理错误
    error -> { /* 处理错误，error类型为Throwable */ }
);

class CustomError extends Throwable {
    private int errorCode;
    private String errorMessage;

    public CustomError(int errorCode, String errorMessage) {
        this.errorCode = errorCode;
        this.errorMessage = errorMessage;
    }

    public int getErrorCode() {
        return errorCode;
    }

    public String getErrorMessage() {
        return errorMessage;
    }
}

Observable.create(emitter -> {
    try {
        // 执行一些操作
        // 如果发生错误，创建自定义错误对象
        emitter.onError(new CustomError(500, "Something went wrong"));
    } catch (Exception e) {
        emitter.onError(e);
    }
})
.subscribe(
    // 处理正常结果
    result -> { /* 处理结果 */ },
    // 处理错误
    error -> {
        if (error instanceof CustomError) {
            CustomError customError = (CustomError) error;
            // 使用自定义错误对象中的属性处理错误
        }
    }
);