simple web flux

Author: Freeongoo

web-flux-and-mono/src/test/java/com/example/demo/FluxTest.java

@@ -1,5 +1,6 @@
 package com.example.demo;
 
+import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 import reactor.core.publisher.Flux;
 
@@ -19,6 +20,44 @@ void flux() {
         fluxUsers.subscribe(System.out::println);
     }
 
+    // complete - не выводится так как было прокинуто исключение, которое мы обработали и вывели
+    @Test
+    void fluxError_WhenHandleError() {
+        Flux<Integer> ints = Flux.range(1, 6)
+                .map(i -> {
+                    if (i <= 3) return i;
+                    throw new RuntimeException("Got to 4");
+                });
+        ints.subscribe(
+                i -> System.out.println(i),
+                error -> System.err.println("Error: " + error),
+                () -> System.out.println("complete")
+        );
+    }
+
+    @Test
+    void fluxError_WhenNotHandleError() {
+        Assertions.assertThrows(RuntimeException.class, () -> {
+            Flux<Integer> ints = Flux.range(1, 6)
+                    .map(i -> {
+                        if (i <= 3) return i;
+                        throw new RuntimeException("Got to 4");
+                    });
+            ints.subscribe(
+                    i -> System.out.println(i)
+            );
+        });
+    }
+
+    @Test
+    void fluxWithRequestCount() {
+        Flux<Integer> ints = Flux.range(1, 4);
+        ints.subscribe(i -> System.out.println(i),
+                error -> System.err.println("Error " + error),
+                () -> System.out.println("Done"),
+                sub -> sub.request(2));
+    }
+
     @Test
     void fluxFilter() {
         Flux<User> userFlux = Flux.just(peter, lois, brain);