Apply Optimize Java 8 Streams refactoring

abstract-document/src/main/java/com/iluwatar/abstractdocument/AbstractDocument.java

@@ -54,9 +54,9 @@ public Object get(String key) {
 
   @Override
   public <T> Stream<T> children(String key, Function<Map<String, Object>, T> constructor) {
-    Optional<List<Map<String, Object>>> any = Stream.of(get(key)).filter(el -> el != null)
+    Optional<List<Map<String, Object>>> any = Stream.of(get(key)).parallel().filter(el -> el != null)
         .map(el -> (List<Map<String, Object>>) el).findAny();
-    return any.isPresent() ? any.get().stream().map(constructor) : Stream.empty();
+    return any.isPresent() ? any.get().parallelStream().map(constructor) : Stream.empty();
   }
 
   @Override

dao/src/main/java/com/iluwatar/dao/DbCustomerDao.java

@@ -86,7 +86,7 @@ public boolean tryAdvance(Consumer<? super Customer> action) {
             throw new RuntimeException(e); // NOSONAR
           }
         }
-      }, false).onClose(() -> mutedClose(connection, statement, resultSet));
+      }, false).parallel().onClose(() -> mutedClose(connection, statement, resultSet));
     } catch (SQLException e) {
       throw new CustomException(e.getMessage(), e);
     }

dao/src/main/java/com/iluwatar/dao/InMemoryCustomerDao.java

@@ -43,7 +43,7 @@ public class InMemoryCustomerDao implements CustomerDao {
    */
   @Override
   public Stream<Customer> getAll() {
-    return idToCustomer.values().stream();
+    return idToCustomer.values().parallelStream();
   }
 
   @Override

eip-message-channel/src/main/java/com/iluwatar/eip/message/channel/App.java

@@ -70,7 +70,7 @@ public void configure() throws Exception {
     });
 
     context.start();
-    context.getRoutes().stream().forEach(r -> LOGGER.info(r.toString()));
+    context.getRoutes().parallelStream().forEach(r -> LOGGER.info(r.toString()));
     context.stop();
   }
 }

eip-publish-subscribe/src/main/java/com/iluwatar/eip/publish/subscribe/App.java

@@ -65,7 +65,7 @@ public void configure() throws Exception {
     });
     ProducerTemplate template = context.createProducerTemplate();
     context.start();
-    context.getRoutes().stream().forEach(r -> LOGGER.info(r.toString()));
+    context.getRoutes().parallelStream().forEach(r -> LOGGER.info(r.toString()));
     template.sendBody("direct:origin", "Hello from origin");
     context.stop();
   }

layers/src/main/java/com/iluwatar/layers/CakeInfo.java

@@ -59,7 +59,7 @@ public CakeInfo(CakeToppingInfo cakeToppingInfo, List<CakeLayerInfo> cakeLayerIn
    */
   public int calculateTotalCalories() {
     int total = cakeToppingInfo != null ? cakeToppingInfo.calories : 0;
-    total += cakeLayerInfos.stream().mapToInt(c -> c.calories).sum();
+    total += cakeLayerInfos.parallelStream().mapToInt(c -> c.calories).sum();
     return total;
   }
 

specification/src/main/java/com/iluwatar/specification/app/App.java

@@ -68,13 +68,13 @@ public static void main(String[] args) {
     // find all walking creatures
     LOGGER.info("Find all walking creatures");
     List<Creature> walkingCreatures =
-        creatures.stream().filter(new MovementSelector(Movement.WALKING))
+        creatures.parallelStream().filter(new MovementSelector(Movement.WALKING))
             .collect(Collectors.toList());
     walkingCreatures.stream().forEach(c -> LOGGER.info(c.toString()));
     // find all dark creatures
     LOGGER.info("Find all dark creatures");
     List<Creature> darkCreatures =
-        creatures.stream().filter(new ColorSelector(Color.DARK)).collect(Collectors.toList());
+        creatures.parallelStream().filter(new ColorSelector(Color.DARK)).collect(Collectors.toList());
     darkCreatures.stream().forEach(c -> LOGGER.info(c.toString()));
     // find all red and flying creatures
     LOGGER.info("Find all red and flying creatures");

thread-pool/src/test/java/com/iluwatar/threadpool/TaskTest.java

@@ -94,14 +94,15 @@ public void testIdGeneration() throws Exception {
       }
 
       final List<Integer> ids = service.invokeAll(tasks)
-          .stream()
+          .parallelStream()
           .map(TaskTest::get)
           .filter(Objects::nonNull)
           .collect(Collectors.toList());
 
       service.shutdownNow();
 
-      final long uniqueIdCount = ids.stream()
+      final long uniqueIdCount = ids.parallelStream()
+          .unordered()
           .distinct()
           .count();