Remove code

Author: alejandro-du

blocking-service/src/main/java/com/example/Word.java

@@ -1,18 +1,14 @@
 package com.example;
 
-import java.util.concurrent.TimeUnit;
-
 public class Application {
 
-	public static void main(String[] args) throws InterruptedException {
+	public static void main(String[] args) {
 		for (int u = 1; u <= 10; u++) {
 			var user = "User " + u;
-			Service.getFlux()
-					.map(i -> user + " - " + i)
-					.subscribe(System.out::println);
+			Service.getStream()
+					.mapToObj(i -> user + " - " + i)
+					.forEach(System.out::println);
 		}
-
-		TimeUnit.SECONDS.sleep(5);
 	}
 
 }

blocking-service/src/main/java/com/example/WordRepository.java

@@ -1,8 +1,5 @@
 package com.example;
 
-import reactor.core.publisher.Flux;
-
-import java.time.Duration;
 import java.util.stream.IntStream;
 
 public class Service {
@@ -17,9 +14,4 @@ public static IntStream getStream() {
         });
     }
 
-    public static Flux<Integer> getFlux() {
-        return Flux.interval(Duration.ofSeconds(1))
-                .map(l -> (int) (Math.random() * 10));
-    }
-
 }

blocking-service/src/main/java/com/example/WordService.java

@@ -1,14 +1,3 @@
 server.port=9090
 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.security.reactive.ReactiveSecurityAutoConfiguration
 
-spring.r2dbc.url=r2dbc:mariadb://localhost:3306/wordle
-spring.r2dbc.username=user
-spring.r2dbc.password=password
-spring.r2dbc.pool.max-size=10
-spring.r2dbc.pool.max-create-connection-time=10s
-
-# If you are using MariaDB SkySQL (https://mariadb.com/products/skysql),
-# enable SSL and specify the path to the CA chain file that you can download
-# from the SkySQL Portal (https://cloud.mariadb.com):
-#
-# spring.r2dbc.url=r2dbc:mariadb://demo-db0000xxxx.mdb000xxxx.db.skysql.net:5047/reactive-demo?sslMode=VERIFY_CA&serverSslCert=/path/to/skysql_chain.pem