DebuggingWithOutCheckpoints.java

private static void debuggingWithOutCheckpoints() {
        List<String> nameList = Arrays.asList("Rochel", "April", "Hong");

        Flux<String> stringFlux = Flux.fromIterable(nameList)
                .distinct()
                .map(name -> name.substring(0, 3))
                .map(String::toUpperCase)
                .map(name -> {
                    if (name.equals("HON")) {
                        throw new RuntimeException("Boom!");
                    } else {
                        return name;
                    }
                });
        stringFlux.subscribe(log::info);
}