CompletionOrderSpliterator.java

1
package com.pivovarit.collectors;
2
3
import java.util.List;
4
import java.util.Spliterator;
5
import java.util.concurrent.BlockingQueue;
6
import java.util.concurrent.CompletableFuture;
7
import java.util.concurrent.LinkedBlockingQueue;
8
import java.util.function.Consumer;
9
10
/**
11
 * @author Grzegorz Piwowarek
12
 */
13
final class CompletionOrderSpliterator<T> implements Spliterator<T> {
14
15
    private final int initialSize;
16
    private final BlockingQueue<CompletableFuture<T>> completed = new LinkedBlockingQueue<>();
17
    private int remaining;
18
19
    CompletionOrderSpliterator(List<CompletableFuture<T>> futures) {
20
        this.initialSize = futures.size();
21
        this.remaining = initialSize;
22 1 1. <init> : removed call to java/util/List::forEach → TIMED_OUT
        futures.forEach(f -> f.whenComplete((__, ___) -> completed.add(f)));
23
    }
24
25
    @Override
26
    public boolean tryAdvance(Consumer<? super T> action) {
27 3 1. tryAdvance : changed conditional boundary → TIMED_OUT
2. tryAdvance : negated conditional → TIMED_OUT
3. tryAdvance : replaced boolean return with true for com/pivovarit/collectors/CompletionOrderSpliterator::tryAdvance → KILLED
        return remaining > 0
28 1 1. lambda$tryAdvance$2 : replaced Boolean return with False for com/pivovarit/collectors/CompletionOrderSpliterator::lambda$tryAdvance$2 → KILLED
          ? nextCompleted().thenAccept(action).thenApply(__ -> true).join()
29
          : false;
30
    }
31
32
    private CompletableFuture<T> nextCompleted() {
33 1 1. nextCompleted : Replaced integer subtraction with addition → TIMED_OUT
        remaining--;
34
        try {
35 1 1. nextCompleted : replaced return value with null for com/pivovarit/collectors/CompletionOrderSpliterator::nextCompleted → KILLED
            return completed.take();
36
        } catch (InterruptedException e) {
37 1 1. nextCompleted : removed call to java/lang/Thread::interrupt → TIMED_OUT
            Thread.currentThread().interrupt();
38
39
            throw new RuntimeException(e);
40
        }
41
    }
42
43
    @Override
44
    public Spliterator<T> trySplit() {
45
        return null;
46
    }
47
48
    @Override
49
    public long estimateSize() {
50 1 1. estimateSize : replaced long return with 0 for com/pivovarit/collectors/CompletionOrderSpliterator::estimateSize → SURVIVED
        return initialSize;
51
    }
52
53
    @Override
54
    public int characteristics() {
55 1 1. characteristics : replaced int return with 0 for com/pivovarit/collectors/CompletionOrderSpliterator::characteristics → SURVIVED
        return SIZED | IMMUTABLE | NONNULL;
56
    }
57
}
58
59

Mutations

22

1.1
Location : <init>
Killed by : none
removed call to java/util/List::forEach → TIMED_OUT

27

1.1
Location : tryAdvance
Killed by : none
changed conditional boundary → TIMED_OUT

2.2
Location : tryAdvance
Killed by : none
negated conditional → TIMED_OUT

3.3
Location : tryAdvance
Killed by : com.pivovarit.collectors.CompletionOrderSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.CompletionOrderSpliteratorTest]/[method:shouldNotConsumeOnEmpty()]
replaced boolean return with true for com/pivovarit/collectors/CompletionOrderSpliterator::tryAdvance → KILLED

28

1.1
Location : lambda$tryAdvance$2
Killed by : com.pivovarit.collectors.CompletionOrderSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.CompletionOrderSpliteratorTest]/[method:shouldPropagateException()]
replaced Boolean return with False for com/pivovarit/collectors/CompletionOrderSpliterator::lambda$tryAdvance$2 → KILLED

33

1.1
Location : nextCompleted
Killed by : none
Replaced integer subtraction with addition → TIMED_OUT

35

1.1
Location : nextCompleted
Killed by : com.pivovarit.collectors.CompletionOrderSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.CompletionOrderSpliteratorTest]/[method:shouldStreamInCompletionOrder()]
replaced return value with null for com/pivovarit/collectors/CompletionOrderSpliterator::nextCompleted → KILLED

37

1.1
Location : nextCompleted
Killed by : none
removed call to java/lang/Thread::interrupt → TIMED_OUT

50

1.1
Location : estimateSize
Killed by : none
replaced long return with 0 for com/pivovarit/collectors/CompletionOrderSpliterator::estimateSize → SURVIVED

55

1.1
Location : characteristics
Killed by : none
replaced int return with 0 for com/pivovarit/collectors/CompletionOrderSpliterator::characteristics → SURVIVED

Active mutators

Tests examined


Report generated by PIT 1.9.8