Spring Reactor:当publisher发出一个值时，如何抛出异常？

import reactor.core.publisher.Flux;

public class ExceptionHandlingExample {
    public static void main(String[] args) {
        Flux<Integer> numbers = Flux.just(1, 2, 3, 4, 5);

        numbers.map(number -> {
            if (number == 3) {
                throw new RuntimeException("Exception occurred!");
            }
            return number;
        })
        .onErrorResume(throwable -> {
            System.out.println("Exception handled: " + throwable.getMessage());
            return Flux.empty();
        })
        .subscribe(System.out::println);
    }
}