RxJava +改装失败时返回自定义异常

public class CustomException extends RuntimeException {
    public CustomException(String message) {
        super(message);
    }
}

Observable<Integer> observable = Observable.create(emitter -> {
    // 模拟一个错误
    emitter.onError(new Throwable("Something went wrong"));
});

observable
    .onErrorReturn(throwable -> {
        // 返回一个默认值，并抛出自定义异常
        throw new CustomException("Custom error message");
    })
    .subscribe(
        value -> System.out.println("Received: " + value),
        error -> System.out.println("Error: " + error.getMessage())
    );

Observable<Integer> observable = Observable.create(emitter -> {
    // 模拟一个错误
    emitter.onError(new Throwable("Something went wrong"));
});

observable
    .onErrorResumeNext(throwable -> {
        // 返回一个包含自定义异常的Observable
        return Observable.error(new CustomException("Custom error message"));
    })
    .subscribe(
        value -> System.out.println("Received: " + value),
        error -> System.out.println("Error: " + error.getMessage())
    );

observable
    .onErrorResumeNext(throwable -> {
        return Observable.error(new CustomException("Custom error message"));
    })
    .subscribe(
        value -> System.out.println("Received: " + value),
        error -> {
            if (error instanceof CustomException) {
                System.out.println("Custom error occurred: " + error.getMessage());
            } else {
                System.out.println("Other error occurred: " + error.getMessage());
            }
        }
    );