Package org.n52.janmayen.stream

Class MoreCollectors

java.lang.Object

org.n52.janmayen.stream.MoreCollectors

public final class MoreCollectors
extends Object

TODO JavaDoc

Method Summary

Modifier and Type	Method	Description
static <T,A,R> Collector<T,?,R>	collector(Supplier<A> supplier, BiConsumer<A,T> accumulator, BiConsumer<A,A> combiner, Function<A,R> finisher)
static <T,R> Collector<T,?,R>	collector(Supplier<R> supplier, BiConsumer<R,T> accumulator, BiConsumer<R,R> combiner)
static <T,A,R> Collector<T,A,R>	filtering(Predicate<T> filter, Collector<T,A,R> downstream)
static <T,U,A,R> Collector<T,?,R>	flatMapping(Function<? super T,? extends Stream<? extends U>> mapper, Collector<? super U,A,R> downstream)
static <X,T> Collector<X,?,Map<Chain<T>,BigInteger>>	toCardinalities(Function<X,T> id, Predicate<X> hasSubElements, Function<X,Stream<X>> subElements)
static <X,T> Collector<X,?,Map<Chain<T>,X>>	toChain(Function<X,T> id, Predicate<X> hasSubElements, Function<X,Stream<X>> subElements)
static <X,T,U> Collector<X,?,Map<Chain<T>,U>>	toChain(Function<X,T> id, Predicate<X> hasSubElements, Function<X,Stream<X>> subElements, Function<X,U> finisher)
static <T,E extends Exception,X extends CompositeException> Collector<T,?,X>	toCompositeException(Supplier<X> supplier, ThrowingConsumer<? super T,E> fun)
static <T,E extends Exception> Collector<T,?,CompositeException>	toCompositeException(ThrowingConsumer<? super T,E> fun)
static <X> Collector<X,?,Set<X>>	toDuplicateSet()
static <X> Collector<X,?,Set<X>>	toDuplicateSet(int min)
static <X> Collector<X,?,Stream<X>>	toDuplicateStream()
static <X> Collector<X,?,Stream<X>>	toDuplicateStream(int min)
static <K,V> Collector<Map.Entry<K,V>,?,LinkedHashMap<K,V>>	toLinkedHashMap()
static <T> Collector<T,?,T>	toSingleResult()
static <T> Collector<T,?,T>	toSingleResult(Supplier<? extends RuntimeException> exceptionSupplier)
static <T> Collector<T,?,List<T>>	toUnmodifiableList()	Returns a Collector that accumulates the input elements into a new unmodifiable List.
static <T> Collector<T,?,Set<T>>	toUnmodifiableSet()	Returns a Collector that accumulates the input elements into a new unmodifiable Set.
static <K,V> Collector<Map.Entry<K,V>,?,Map<V,K>>	toValueMap()

Methods inherited from class java.lang.Object

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

Method Detail

toUnmodifiableSet

public static <T> Collector<T,?,Set<T>> toUnmodifiableSet()

Returns a Collector that accumulates the input elements into a new unmodifiable Set.

Type Parameters:

T - the element type

Returns:

the collector

toUnmodifiableList

public static <T> Collector<T,?,List<T>> toUnmodifiableList()

Returns a Collector that accumulates the input elements into a new unmodifiable List.

Type Parameters:

T - the element type

Returns:

the collector

filtering

public static <T,A,R> Collector<T,A,R> filtering(Predicate<T> filter,
                                                                         Collector<T,A,R> downstream)

flatMapping

public static <T,U,A,R> Collector<T,?,R> flatMapping(Function<? super T,? extends Stream<? extends U>> mapper,
                                                                                   Collector<? super U,A,R> downstream)

toCardinalities

public static <X,T> Collector<X,?,Map<Chain<T>,BigInteger>> toCardinalities(Function<X,T> id,
                                                                                                    Predicate<X> hasSubElements,
                                                                                                    Function<X,Stream<X>> subElements)

toChain

public static <X,T> Collector<X,?,Map<Chain<T>,X>> toChain(Function<X,T> id,
                                                                                   Predicate<X> hasSubElements,
                                                                                   Function<X,Stream<X>> subElements)

toChain

public static <X,T,U> Collector<X,?,Map<Chain<T>,U>> toChain(Function<X,T> id,
                                                                                           Predicate<X> hasSubElements,
                                                                                           Function<X,Stream<X>> subElements,
                                                                                           Function<X,U> finisher)

toDuplicateSet

public static <X> Collector<X,?,Set<X>> toDuplicateSet()

toDuplicateSet

public static <X> Collector<X,?,Set<X>> toDuplicateSet(int min)

toDuplicateStream

public static <X> Collector<X,?,Stream<X>> toDuplicateStream()

toDuplicateStream

public static <X> Collector<X,?,Stream<X>> toDuplicateStream(int min)

toSingleResult

public static <T> Collector<T,?,T> toSingleResult()

toSingleResult

public static <T> Collector<T,?,T> toSingleResult(Supplier<? extends RuntimeException> exceptionSupplier)

toValueMap

public static <K,V> Collector<Map.Entry<K,V>,?,Map<V,K>> toValueMap()

toLinkedHashMap

public static <K,V> Collector<Map.Entry<K,V>,?,LinkedHashMap<K,V>> toLinkedHashMap()

collector

public static <T,R> Collector<T,?,R> collector(Supplier<R> supplier,
                                                                 BiConsumer<R,T> accumulator,
                                                                 BiConsumer<R,R> combiner)

collector

public static <T,A,R> Collector<T,?,R> collector(Supplier<A> supplier,
                                                                         BiConsumer<A,T> accumulator,
                                                                         BiConsumer<A,A> combiner,
                                                                         Function<A,R> finisher)

toCompositeException

public static <T,E extends Exception> Collector<T,?,CompositeException> toCompositeException(ThrowingConsumer<? super T,E> fun)

toCompositeException

public static <T,E extends Exception,X extends CompositeException> Collector<T,?,X> toCompositeException(Supplier<X> supplier,
                                                                                                                                 ThrowingConsumer<? super T,E> fun)