Rename methods and use only 10 "users"

Author: alejandro-du

reactive-programming/src/main/java/com/example/Application.java

@@ -8,14 +8,15 @@ public class Application {
     public static void main(String[] args) {
         ExecutorService threadPool = Executors.newFixedThreadPool(2);
 
-        for (int u = 1; u <= 100; u++) {
+        for (int u = 1; u <= 10; u++) {
             var user = "User " + u;
+            System.out.println("Subscribing to flux " + u);
             threadPool.submit(() -> {
-                Service.getNumberFlux()
-                        .map(i -> user + ": " + i)
+                Service.getFlux()
+                        .map(i -> user + " - " + i)
                         .subscribe(System.out::println);
             });
         }
-
     }
+
 }

reactive-programming/src/main/java/com/example/Service.java

@@ -7,7 +7,7 @@
 
 public class Service {
 
-    public static IntStream getNumberStream() {
+    public static IntStream getStream() {
         return IntStream.generate(() -> {
             try {
                 Thread.sleep(1000);
@@ -17,7 +17,7 @@ public static IntStream getNumberStream() {
         });
     }
 
-    public static Flux<Integer> getNumberFlux() {
+    public static Flux<Integer> getFlux() {
         return Flux.interval(Duration.ofSeconds(1))
                 .map(l -> (int) (Math.random() * 10));
     }