AsyncCollector.java

1 
/*
2 
 * Copyright 2014-2026 Grzegorz Piwowarek, https://4comprehension.com/
3 
 *
4 
 * Licensed under the Apache License, Version 2.0 (the "License");
5 
 * you may not use this file except in compliance with the License.
6 
 * You may obtain a copy of the License at
7 
 *
8 
 * https://www.apache.org/licenses/LICENSE-2.0
9 
 *
10 
 * Unless required by applicable law or agreed to in writing, software
11 
 * distributed under the License is distributed on an "AS IS" BASIS,
12 
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 
 * See the License for the specific language governing permissions and
14 
 * limitations under the License.
15 
 */
16 
package com.pivovarit.collectors;
17
18 
import java.util.Set;
19 
import java.util.concurrent.CompletableFuture;
20 
import java.util.concurrent.Executor;
21 
import java.util.function.BiConsumer;
22 
import java.util.function.BinaryOperator;
23 
import java.util.function.Function;
24 
import java.util.function.Supplier;
25 
import java.util.stream.Collector;
26 
import java.util.stream.Stream;
27
28 
record AsyncCollector<T, R, RR>(Function<? super T, ? extends R> mapper, Function<Stream<R>, RR> processor, Executor executor)
29 
  implements Collector<T, Stream.Builder<T>, CompletableFuture<RR>> {
30
31 
    @Override
32 
    public Supplier<Stream.Builder<T>> supplier() {
33 1 1. supplier : replaced return value with null for com/pivovarit/collectors/AsyncCollector::supplier → KILLED
 
        return Stream::builder;
34 
    }
35
36 
    @Override
37 
    public BiConsumer<Stream.Builder<T>, T> accumulator() {
38 1 1. accumulator : replaced return value with null for com/pivovarit/collectors/AsyncCollector::accumulator → KILLED
 
        return Stream.Builder::add;
39 
    }
40
41 
    @Override
42 
    public BinaryOperator<Stream.Builder<T>> combiner() {
43 1 1. combiner : replaced return value with null for com/pivovarit/collectors/AsyncCollector::combiner → SURVIVED
 
        return (left, right) -> {
44 
            throw new UnsupportedOperationException("using parallel stream with parallel collectors is not supported");
45 
        };
46 
    }
47
48 
    @Override
49 
    public Function<Stream.Builder<T>, CompletableFuture<RR>> finisher() {
50 1 1. finisher : replaced return value with null for com/pivovarit/collectors/AsyncCollector::finisher → KILLED
 
        return acc -> {
51 
            try {
52 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);
53 
            } catch (Exception e) {
54 1 1. lambda$finisher$0 : replaced return value with null for com/pivovarit/collectors/AsyncCollector::lambda$finisher$0 → KILLED
 
                return CompletableFuture.failedFuture(e);
55 
            }
56 
        };
57 
    }
58
59 
    @Override
60 
    public Set<Characteristics> characteristics() {
61 
        return Set.of();
62 
    }
63 
}

Mutations

33

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

38

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

43

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

50

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

52

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

54

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

Active mutators

Tests examined


Report generated by PIT 1.22.0