spring-boot-rest/spring-5-reactive-2/src/main/java/com/baeldung/webflux/logging/WebFluxLoggingExample.java

package com.baeldung.webflux.logging;

import reactor.core.publisher.Flux;

public class WebFluxLoggingExample {

    public static void main(String[] args) {
        Flux<Integer> reactiveStream = Flux.range(1, 5).log();

        reactiveStream.subscribe();

        reactiveStream = Flux.range(1, 5).log().take(3);

        reactiveStream.subscribe();

        reactiveStream = Flux.range(1, 5).take(3).log();

        reactiveStream.subscribe();
    }

}