Make the processing parallel

nsamoylov · nsamoylov · commit 90db960d9e94 · 2022-04-04T16:38:06.000-06:00
diff --git a/streams/src/main/java/com/packt/learnjava/streams/Main.java b/streams/src/main/java/com/packt/learnjava/streams/Main.java
@@ -51,13 +51,15 @@ public static void main(String[] args) {
     private static List<Person> getInputPersonList(File file) throws IOException {
         return Files.lines(file.toPath())
                 .skip(1)
+                .parallel()
                 .map(Main::validLine)
                 .map(l -> {
                     Person person = new Person(Integer.parseInt(l.get(2)), l.get(0), l.get(1));
                     person.setAddress(l.get(3), l.get(4), l.get(5), Integer.parseInt(l.get(6)));
                     return person;
                 }).toList();
     }
+
     private static List<String> validLine(String line){
         List<String> values = new ArrayList<>();
         String[] arr = line.split(",");
