@@ -0,0 +1,604 @@
+package com.etroya.reactivespring.reactivespring;%0A%0Aimport org.junit.jupiter.api.Test;%0Aimport reactor.core.publisher.Flux;%0A%0Apublic class FluxAndMonoTest %7B%0A%0A    @Test%0A    void fluxTest() %7B%0A    Flux%3CString%3E stringFlux = Flux.just(%22Spring%22, %22Spring boot%22, %22Reactive Spring%22)%0A//            .concatWith(Flux.error(new RuntimeException(%22Exception occured%22)))%0A            .concatWith(Flux.just(%22After error%22))%0A            .log();%0A    stringFlux.subscribe(System.out::println,%0A            (e) -%3E System.err.println(%22Exception is: %22 + e),%0A            ()  -%3E System.out.println(%22Completed%22)%0A            );%0A%0A    %7D%0A%7D%0A

test with flux