@@ -0,0 +1,861 @@
+package com.example.spring.react.service;%0A%0Aimport reactor.core.publisher.Flux;%0A%0Aimport java.util.stream.Collectors;%0Aimport java.util.stream.Stream;%0A%0Apublic class ReactiveService %7B%0A%0A    public static void main(String%5B%5D args) %7B%0A        Flux%3CString%3E flux = Flux.just(%22One%22, %22Two%22, %22Three%22);%0A        Flux.range(5, 3)%0A                .subscribe(System.out::println);%0A        Flux.fromIterable(Stream.of(%22One%22, %22Two%22, %22Three%22).collect(Collectors.toList()))%0A                .subscribe(System.out::println);%0A        Flux.range(1, 4)%0A                .map(i -%3E %7B%0A                    if (i %3C= 3) return i;%0A                    throw new RuntimeException(%22Got to 4%22);%0A                %7D)%0A                .subscribe(System.out::println,%0A                        error -%3E System.err.println(%22Error: %22 + error),%0A                        () -%3E System.out.println(%22Done%22));%0A    %7D%0A%7D%0A

Add examples of flux generation