AsyncCollector.java

1 
package com.pivovarit.collectors;
2
3 
import java.util.Set;
4 
import java.util.concurrent.CompletableFuture;
5 
import java.util.concurrent.CompletionException;
6 
import java.util.concurrent.Executor;
7 
import java.util.function.BiConsumer;
8 
import java.util.function.BinaryOperator;
9 
import java.util.function.Function;
10 
import java.util.function.Supplier;
11 
import java.util.stream.Collector;
12 
import java.util.stream.Stream;
13
14 
record AsyncCollector<T, R, RR>(Function<? super T, ? extends R> mapper, Function<Stream<R>, RR> processor, Executor executor)
15 
  implements Collector<T, Stream.Builder<T>, CompletableFuture<RR>> {
16
17 
    @Override
18 
    public Supplier<Stream.Builder<T>> supplier() {
19 1 1. supplier : replaced return value with null for com/pivovarit/collectors/AsyncCollector::supplier → KILLED
 
        return Stream::builder;
20 
    }
21
22 
    @Override
23 
    public BiConsumer<Stream.Builder<T>, T> accumulator() {
24 1 1. accumulator : replaced return value with null for com/pivovarit/collectors/AsyncCollector::accumulator → KILLED
 
        return Stream.Builder::add;
25 
    }
26
27 
    @Override
28 
    public BinaryOperator<Stream.Builder<T>> combiner() {
29 1 1. combiner : replaced return value with null for com/pivovarit/collectors/AsyncCollector::combiner → SURVIVED
 
        return (left, right) -> {
30 1 1. lambda$combiner$0 : removed call to java/util/stream/Stream::forEach → NO_COVERAGE
 
            right.build().forEach(left::add);
31 1 1. lambda$combiner$0 : replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$combiner$0 → NO_COVERAGE
 
            return left;
32 
        };
33 
    }
34
35 
    @Override
36 
    public Function<Stream.Builder<T>, CompletableFuture<RR>> finisher() {
37 1 1. finisher : replaced return value with null for com/pivovarit/collectors/AsyncCollector::finisher → KILLED
 
        return acc -> {
38 
            try {
39 2 1. lambda$finisher$1 : replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$finisher$1 → KILLED
2. lambda$finisher$0 : replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$finisher$0 → KILLED
 
                return CompletableFuture.supplyAsync(() -> processor.apply(acc.build().map(mapper)), executor);
40 
            } catch (Exception e) {
41 
                throw new CompletionException(e);
42 
            }
43 
        };
44 
    }
45
46 
    @Override
47 
    public Set<Characteristics> characteristics() {
48 
        return Set.of();
49 
    }
50 
}

Mutations

19

1.1
Location : supplier
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessEmptyWithMaxParallelism()]/[dynamic-test:#3] replaced return value with null for com/pivovarit/collectors/AsyncCollector::supplier → KILLED

24

1.1
Location : accumulator
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessAllElementsWithMaxParallelism()]/[dynamic-test:#3] replaced return value with null for com/pivovarit/collectors/AsyncCollector::accumulator → KILLED

29

1.1
Location : combiner
Killed by : none replaced return value with null for com/pivovarit/collectors/AsyncCollector::combiner → SURVIVED Covering tests

30

1.1
Location : lambda$combiner$0
Killed by : none removed call to java/util/stream/Stream::forEach → NO_COVERAGE

31

1.1
Location : lambda$combiner$0
Killed by : none replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$combiner$0 → NO_COVERAGE

37

1.1
Location : finisher
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessEmptyWithMaxParallelism()]/[dynamic-test:#3] replaced return value with null for com/pivovarit/collectors/AsyncCollector::finisher → KILLED

39

1.1
Location : lambda$finisher$1
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessEmptyWithMaxParallelism()]/[dynamic-test:#3] replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$finisher$1 → KILLED

2.2
Location : lambda$finisher$0
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessEmptyWithMaxParallelism()]/[dynamic-test:#3] replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$finisher$0 → KILLED

Active mutators

Tests examined


Report generated by PIT 1.19.4