com.github.leeonky.dal.runtime

Class FunctionUtil

java.lang.Object

com.github.leeonky.dal.runtime.FunctionUtil

public class FunctionUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
FunctionUtil()

Method Summary

Modifier and Type	Method and Description
static <T> java.util.List<T>	allOptional(java.util.function.Supplier<java.util.Optional<T>> optional)
static <T> void	eachWithIndex(java.util.stream.Stream<T> stream, java.util.function.BiConsumer<java.lang.Integer,T> consumer)
static <T> T	getValue(java.util.function.Supplier<? extends T> supplier, java.util.function.Supplier<? extends T>... suppliers)
static <T,R> java.util.stream.Stream<R>	mapWithIndex(java.util.stream.Stream<T> stream, java.util.function.BiFunction<java.lang.Integer,T,R> biFunction)
static <T> java.util.function.Predicate<T>	not(java.util.function.Predicate<T> t)
static <T> java.util.function.BinaryOperator<T>	notAllowParallelReduce()
static <T> java.util.Optional<T>	oneOf(java.util.function.Supplier<java.util.Optional<? extends T>>... optionals)
static <T> java.util.List<java.util.List<T>>	transpose(java.util.List<java.util.List<T>> list)
static <T> java.util.stream.Stream<java.util.List<T>>	transpose(java.util.stream.Stream<java.util.List<T>> list)
static <A,B,C> java.util.stream.Stream<C>	zip(java.util.stream.Stream<A> streamA, java.util.stream.Stream<B> streamB, java.util.function.BiFunction<A,B,C> zipper)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FunctionUtil

public FunctionUtil()

Method Detail

not

public static <T> java.util.function.Predicate<T> not(java.util.function.Predicate<T> t)

oneOf

@SafeVarargs
public static <T> java.util.Optional<T> oneOf(java.util.function.Supplier<java.util.Optional<? extends T>>... optionals)

getValue

@SafeVarargs
public static <T> T getValue(java.util.function.Supplier<? extends T> supplier,
                                          java.util.function.Supplier<? extends T>... suppliers)

allOptional

public static <T> java.util.List<T> allOptional(java.util.function.Supplier<java.util.Optional<T>> optional)

transpose

public static <T> java.util.List<java.util.List<T>> transpose(java.util.List<java.util.List<T>> list)

transpose

public static <T> java.util.stream.Stream<java.util.List<T>> transpose(java.util.stream.Stream<java.util.List<T>> list)

zip

public static <A,B,C> java.util.stream.Stream<C> zip(java.util.stream.Stream<A> streamA,
                                                     java.util.stream.Stream<B> streamB,
                                                     java.util.function.BiFunction<A,B,C> zipper)

eachWithIndex

public static <T> void eachWithIndex(java.util.stream.Stream<T> stream,
                                     java.util.function.BiConsumer<java.lang.Integer,T> consumer)

mapWithIndex

public static <T,R> java.util.stream.Stream<R> mapWithIndex(java.util.stream.Stream<T> stream,
                                                            java.util.function.BiFunction<java.lang.Integer,T,R> biFunction)

notAllowParallelReduce

public static <T> java.util.function.BinaryOperator<T> notAllowParallelReduce()