iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Grzegorz Piwowarek 2024-02-07 18:06:50 +01:00
parent 1b51c108ff
commit 348b9cfa5e
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
libraries-stream/src/test/java/com/baeldung/parallel_collectors/ParallelCollectorsUnitTest.java
View File

@ -37,16 +37,15 @@ public class ParallelCollectorsUnitTest {
}
@Test
public void shouldProcessInParallelWithParallelCollectors() {
public void shouldCollectInParallel() {
ExecutorService executor = Executors.newFixedThreadPool(10);
List<Integer> ids = Arrays.asList(1, 2, 3);
CompletableFuture<String> results = ids.stream()
.collect(parallel(ParallelCollectorsUnitTest::fetchById, executor, 4))
.thenApply(s -> s.reduce("", (s1, s2) -> s1 + s2));
CompletableFuture<Stream<String>> results = ids.stream()
.collect(parallel(ParallelCollectorsUnitTest::fetchById, executor, 4));
assertThat(results.join()).contains("user-1user-2user-3");
assertThat(results.join()).containsExactly("user-1", "user-2", "user-3");
}
@Test