DebuggingUsingCheckpoints.java

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

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

        stringFlux.subscribe(log::info);
}