reactor

Author: meowpunch

pom.xml

@@ -45,6 +45,11 @@
             <artifactId>reactive-streams</artifactId>
             <version>1.0.4</version>
         </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-core</artifactId>
+            <version>3.4.23</version>
+        </dependency>
     </dependencies>
 
 </project>

src/main/java/concurrency/reactive/PubSub.java

@@ -13,7 +13,7 @@ public class PubSub {
       pub -> [Data1] -> mapPub (operator) -> [Data2] -> sub
    */
   public static void main(String[] args) {
-    Publisher<Integer> pub = streamPublisher(Stream.iterate(1, i -> i + 1) );
+    Publisher<Integer> pub = streamPublisher(Stream.iterate(1, i -> i + 1));
     Publisher<Integer> pub1= mapPub(pub, i -> i * 10);
 //    Publisher<Integer> pub2 = reducePub(pub1, 0, Integer::sum);
     var pub2 = reducePub(pub1, new StringBuilder(), (sb, i) -> sb.append(i).append(". "));

src/main/java/concurrency/reactive/ReactorEx.java

@@ -0,0 +1,16 @@
+package concurrency.reactive;
+
+import reactor.core.publisher.Flux;
+
+public class ReactorEx {
+
+  /*
+      Reactor is a reactive library which implements Reactive Streams Specification. Spring choose reactor by default.
+   */
+  public static void main(String[] args) {
+    Flux.range(1, 10)
+        .map(i -> i * 10)
+        .reduce(Integer::sum)
+        .subscribe(System.out::println);
+  }
+}