leeonky / test-charm-java / 314

Committed 27 Sep 2025 03:28PM UTC coverage: 71.169% (-3.2%) from 74.329%

Build # 314

Build Type

push

circleci

Committed by

leeonky

Commit Message

Update version

Run Details

7013 of 9854 relevant lines covered (71.17%)

0.71 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

54.55

/bean-util/src/main/java/com/github/leeonky/util/function/Extension.java

package com.github.leeonky.util.function;

import java.util.Arrays;
import java.util.Collection;
import java.util.Objects;
import java.util.Optional;
import java.util.function.BinaryOperator;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.function.Supplier;
import java.util.stream.Stream;

import static java.util.stream.Stream.of;

public class Extension {

    @SuppressWarnings("unchecked")
    public static <T> Predicate<T> not(Predicate<? extends T> t) {
        Objects.requireNonNull(t);
        return (Predicate<T>) t.negate();
    }

    @SafeVarargs
    @SuppressWarnings("unchecked")
    public static <T> Optional<T> getFirstPresent(Supplier<? extends Optional<? extends T>>... optionals) {
        return (Optional<T>) of(optionals).map(Supplier::get).filter(Optional::isPresent).map(Optional::get).findFirst();
    }

    @SafeVarargs
    @SuppressWarnings("unchecked")
    public static <T> Optional<T> firstPresent(Optional<? extends T>... optionals) {
        return (Optional<T>) of(optionals).filter(Optional::isPresent).map(Optional::get).findFirst();
    }

    @SuppressWarnings("unchecked")
    public static <T> Optional<T> firstPresent(Stream<Optional<? extends T>> optionals) {
        return (Optional<T>) optionals.filter(Optional::isPresent).map(Optional::get).findFirst();
    }

    public static <T> BinaryOperator<T> notAllowParallelReduce() {
        return (o1, o2) -> {
            throw new IllegalStateException("Not allow parallel here!");
        };
    }

    public static <E, R> Optional<R> mapFirst(Collection<? extends E> collection, Function<E, Optional<R>> mapper) {
        return collection.stream().map(mapper).filter(Optional::isPresent).map(Optional::get).findFirst();
    }

    public static <E, R> Optional<R> mapFirst(E[] collection, Function<E, Optional<R>> mapper) {
        return Arrays.stream(collection).map(mapper).filter(Optional::isPresent).map(Optional::get).findFirst();
    }

    public static <E, R> Stream<R> mapPresent(Collection<? extends E> collection, Function<E, Optional<R>> mapper) {
        return collection.stream().map(mapper).filter(Optional::isPresent).map(Optional::get);
    }
}

1	package com.github.leeonky.util.function;
2
3	import java.util.Arrays;
4	import java.util.Collection;
5	import java.util.Objects;
6	import java.util.Optional;
7	import java.util.function.BinaryOperator;
8	import java.util.function.Function;
9	import java.util.function.Predicate;
10	import java.util.function.Supplier;
11	import java.util.stream.Stream;
12
13	import static java.util.stream.Stream.of;
14
15	public class Extension {	×
16
17	@SuppressWarnings("unchecked")
18	public static <T> Predicate<T> not(Predicate<? extends T> t) {
19	Objects.requireNonNull(t);	1✔
20	return (Predicate<T>) t.negate();	1✔
21	}
22
23	@SafeVarargs
24	@SuppressWarnings("unchecked")
25	public static <T> Optional<T> getFirstPresent(Supplier<? extends Optional<? extends T>>... optionals) {
26	return (Optional<T>) of(optionals).map(Supplier::get).filter(Optional::isPresent).map(Optional::get).findFirst();	1✔
27	}
28
29	@SafeVarargs
30	@SuppressWarnings("unchecked")
31	public static <T> Optional<T> firstPresent(Optional<? extends T>... optionals) {
32	return (Optional<T>) of(optionals).filter(Optional::isPresent).map(Optional::get).findFirst();	1✔
33	}
34
35	@SuppressWarnings("unchecked")
36	public static <T> Optional<T> firstPresent(Stream<Optional<? extends T>> optionals) {
37	return (Optional<T>) optionals.filter(Optional::isPresent).map(Optional::get).findFirst();	×
38	}
39
40	public static <T> BinaryOperator<T> notAllowParallelReduce() {
41	return (o1, o2) -> {	1✔
42	throw new IllegalStateException("Not allow parallel here!");	1✔
43	};
44	}
45
46	public static <E, R> Optional<R> mapFirst(Collection<? extends E> collection, Function<E, Optional<R>> mapper) {
47	return collection.stream().map(mapper).filter(Optional::isPresent).map(Optional::get).findFirst();	×
48	}
49
50	public static <E, R> Optional<R> mapFirst(E[] collection, Function<E, Optional<R>> mapper) {
51	return Arrays.stream(collection).map(mapper).filter(Optional::isPresent).map(Optional::get).findFirst();	×
52	}
53
54	public static <E, R> Stream<R> mapPresent(Collection<? extends E> collection, Function<E, Optional<R>> mapper) {
55	return collection.stream().map(mapper).filter(Optional::isPresent).map(Optional::get);	×
56	}
57	}

leeonky / test-charm-java / 314

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous