HW4 Optional for each chunk

afomin-basejava · afomin-basejava · commit 872c9c9c2e98 · 2023-06-27T17:24:47.000+03:00
# processChunkGroupedByReason
# executor shutdown
diff --git a/web/upload/src/main/java/ru/javaops/masterjava/upload/UserProcessor.java b/web/upload/src/main/java/ru/javaops/masterjava/upload/UserProcessor.java
@@ -95,6 +95,7 @@ public List<AbandonedEmails> processChunkGroupedByReason(final InputStream is, i
             }
         }
         extractAbandonedEmails(chunk, executor, abandonedEmails);
+        executor.shutdown();
         return abandonedEmails.stream()
                 .collect(Collectors.groupingBy(AbandonedEmails::getReason)).entrySet().stream()
                 .map(entry -> new AbandonedEmails(entry.getValue().stream()

Original file line number	Diff line number	Diff line change
`@@ -95,6 +95,7 @@ public List<AbandonedEmails> processChunkGroupedByReason(final InputStream is, i`
`95`	`95`	`}`
`96`	`96`	`}`
`97`	`97`	`extractAbandonedEmails(chunk, executor, abandonedEmails);`
	`98`	`+ executor.shutdown();`
`98`	`99`	`return abandonedEmails.stream()`
`99`	`100`	`.collect(Collectors.groupingBy(AbandonedEmails::getReason)).entrySet().stream()`
`100`	`101`	`.map(entry -> new AbandonedEmails(entry.getValue().stream()`