feature: added code refactoring changes for 2378 (#2379)

* fix:added code refactoring changes for 2378

* fix:added code refactoring changes for 2378

* build fix for 2378

* fix: updated pom.xml files for 2378 issue

* fix:build fix for 2378 issue

Co-authored-by: aparna <aparna@aparnas-MacBook-Air.local>

fanout-fanin/src/main/java/com/iluwatar/fanout/fanin/App.java

@@ -26,7 +26,6 @@ package com.iluwatar.fanout.fanin;
 
 import java.util.Arrays;
 import java.util.List;
-import java.util.stream.Collectors;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -62,7 +61,7 @@ public class App {
     LOGGER.info("Numbers to be squared and get sum --> {}", numbers);
 
     final List<SquareNumberRequest> requests =
-        numbers.stream().map(SquareNumberRequest::new).collect(Collectors.toList());
+        numbers.stream().map(SquareNumberRequest::new).toList();
 
     var consumer = new Consumer(0L);
 

fanout-fanin/src/main/java/com/iluwatar/fanout/fanin/FanOutFanIn.java

@@ -28,7 +28,6 @@ import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.stream.Collectors;
 
 /**
  * FanOutFanIn class processes long running requests, when any of the processes gets over, result is
@@ -54,7 +53,7 @@ public class FanOutFanIn {
             .map(
                 request ->
                     CompletableFuture.runAsync(() -> request.delayedSquaring(consumer), service))
-            .collect(Collectors.toList());
+            .toList();
 
     CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
 

fanout-fanin/src/test/java/com/iluwatar/fanout/fanin/FanOutFanInTest.java

@@ -29,7 +29,6 @@ import org.junit.jupiter.api.Test;
 
 import java.util.Arrays;
 import java.util.List;
-import java.util.stream.Collectors;
 
 class FanOutFanInTest {
 
@@ -38,7 +37,7 @@ class FanOutFanInTest {
     final List<Long> numbers = Arrays.asList(1L, 3L, 4L, 7L, 8L);
 
     final List<SquareNumberRequest> requests =
-        numbers.stream().map(SquareNumberRequest::new).collect(Collectors.toList());
+        numbers.stream().map(SquareNumberRequest::new).toList();
 
     final Consumer consumer = new Consumer(0L);