review and simplify

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

core-ng-mongo-test/src/test/java/core/framework/mongo/impl/MongoCollectionIntegrationTest.java

@@ -20,7 +20,6 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
@@ -139,7 +138,7 @@ void bulkDelete() {
         List<TestMongoEntity> entities = entities();
         collection.bulkInsert(entities);
 
-        long deletedCount = collection.bulkDelete(entities.stream().map(entity -> entity.id).collect(Collectors.toList()));
+        long deletedCount = collection.bulkDelete(entities.stream().map(entity -> entity.id).toList());
         assertThat(deletedCount).isEqualTo(2);
         entities.forEach(entity -> assertThat(collection.get(entity.id)).isEmpty());
     }

core-ng-search-test/src/test/java/core/framework/search/impl/ElasticSearchIntegrationTest.java

@@ -32,7 +32,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
-import java.util.stream.Collectors;
 
 import static core.framework.search.query.Queries.match;
 import static core.framework.search.query.Queries.range;
@@ -161,20 +160,20 @@ void searchDateRange() {
         request.sorts.add(Sorts.fieldSort("id", SortOrder.Asc));
         SearchResponse<TestDocument> response = documentType.search(request);
         assertThat(response.totalHits).isEqualTo(3);
-        assertThat(response.hits.stream().map(document1 -> document1.stringField).collect(Collectors.toList()))
+        assertThat(response.hits.stream().map(document1 -> document1.stringField).toList())
             .containsOnly("value1", "value2", "value3");
 
         request.query = QueryBuilders.range(r -> r.untyped(u -> u.field("local_time_field").gt(JsonData.of(LocalTime.of(13, 0)))));
         response = documentType.search(request);
         assertThat(response.totalHits).isEqualTo(2);
-        assertThat(response.hits.stream().map(document -> document.stringField).collect(Collectors.toList()))
+        assertThat(response.hits.stream().map(document -> document.stringField).toList())
             .containsOnly("value3", "value4");
 
         request.query = range("zoned_date_time_field", from.toLocalDate(), to.toLocalDate());
         request.sorts.add(Sorts.fieldSort("id", SortOrder.Asc));
         response = documentType.search(request);
         assertThat(response.totalHits).isEqualTo(3);
-        assertThat(response.hits.stream().map(document1 -> document1.stringField).collect(Collectors.toList()))
+        assertThat(response.hits.stream().map(document1 -> document1.stringField).toList())
             .containsOnly("value1", "value2", "value3");
     }
 

core-ng-search/src/main/java/core/framework/search/impl/ElasticSearchTypeImpl.java

@@ -136,7 +136,7 @@ public List<String> complete(CompleteRequest request) {
             List<String> suggestions = response.suggest().values().stream()
                 .flatMap(Collection::stream).flatMap(suggestion -> suggestion.completion().options().stream()).map(CompletionSuggestOption::text)
                 .distinct()
-                .collect(Collectors.toList());
+                .toList();
             options = suggestions.size();
             return suggestions;
         } catch (IOException e) {

core-ng-test/src/main/java/core/framework/test/assertion/EnvResourceAssert.java

@@ -10,7 +10,6 @@
 import java.nio.file.Paths;
 import java.util.List;
 import java.util.Properties;
-import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -58,7 +57,7 @@ private List<Path> resourceDirs() throws IOException {
         try (Stream<Path> stream = Files.list(actual)) {
             return stream.filter(Files::isDirectory)
                 .map(path -> path.resolve("resources")).filter(Files::exists)
-                .collect(Collectors.toList());
+                .toList();
         }
     }
 
@@ -74,7 +73,7 @@ private void assertOverridesDefault(Path resourceDir) throws IOException {
     private void assertPropertyOverridesDefault(Path resourceDir) throws IOException {
         List<Path> propertyFiles;
         try (Stream<Path> stream = Files.walk(resourceDir).filter(path -> path.toString().endsWith(".properties"))) {
-            propertyFiles = stream.collect(Collectors.toList());
+            propertyFiles = stream.toList();
         }
         for (Path propertyFile : propertyFiles) {
             Path defaultPropertyFile = mainResources.resolve(resourceDir.relativize(propertyFile));

ext/log-collector/src/main/java/core/log/LogCollectorApp.java

@@ -11,7 +11,6 @@
 import java.time.Duration;
 import java.util.Arrays;
 import java.util.List;
-import java.util.stream.Collectors;
 
 /**
  * @author neo
@@ -47,6 +46,6 @@ List<String> allowedOrigins(String value) {
 
     private List<String> parseList(String value) {
         String[] origins = Strings.split(value, ',');
-        return Arrays.stream(origins).map(String::strip).collect(Collectors.toList());
+        return Arrays.stream(origins).map(String::strip).toList();
     }
 }

ext/monitor/src/main/java/app/monitor/alert/AlertService.java

@@ -10,7 +10,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.locks.ReentrantLock;
-import java.util.stream.Collectors;
 
 /**
  * @author ericchung, neo
@@ -34,7 +33,7 @@ public AlertService(AlertConfig config) {
         criticalErrors = new Matchers(config.criticalErrors);
         notifications = config.notifications.stream()
             .map(notification -> new Notification(notification.channel, new Matcher(notification.matcher)))
-            .collect(Collectors.toList());
+            .toList();
         timespanInMinutes = config.timespanInHours * 60;
     }