在reactor 3中抛出多个错误

Flux.just(1, 2, 3)
    .flatMap(i -> {
        if (i == 2) {
            return Mono.error(new RuntimeException("Error occurred"));
        }
        return Mono.just(i);
    })
    .onErrorResume(e -> {
        // 处理错误并返回备用数据流或默认值
        return Flux.just(4, 5, 6);
    })
    .subscribe(System.out::println);

Flux.just(1, 2, 3)
    .flatMap(i -> {
        if (i == 2) {
            return Mono.error(new RuntimeException("Error occurred"));
        }
        return Mono.just(i);
    })
    .onErrorContinue((e, o) -> {
        // 处理错误并继续处理下一个元素
        System.out.println("Error occurred: " + e.getMessage());
    })
    .subscribe(System.out::println);

Flux.just(1, 2, 3)
    .flatMap(i -> {
        if (i == 2) {
            return Mono.error(new RuntimeException("Error occurred"));
        }
        return Mono.just(i);
    })
    .onErrorReturn(0)
    .subscribe(System.out::println);