io.micronaut.core.util

Class StreamUtils

java.lang.Object

io.micronaut.core.util.StreamUtils

public class StreamUtils
extends Object

Utility methods for working with streams.

Since:

1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
StreamUtils()

Method Summary

Modifier and Type	Method and Description
static <T,A,D> Collector<T,?,D>	maxAll(Comparator<? super T> comparator, Collector<? super T,A,D> downstream) A collector that returns all results that are the maximum based on the provided comparator.
static <T,A,D> Collector<T,?,D>	minAll(Comparator<? super T> comparator, Collector<? super T,A,D> downstream) A collector that returns all results that are the minimum based on the provided comparator.
static <T> Collector<T,Collection<T>,Collection<T>>	toImmutableCollection()
static <T,A extends Collection<T>> Collector<T,A,Collection<T>>	toImmutableCollection(Supplier<A> collectionFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamUtils

public StreamUtils()

Method Detail

maxAll

public static <T,A,D> Collector<T,?,D> maxAll(Comparator<? super T> comparator,
                                              Collector<? super T,A,D> downstream)

A collector that returns all results that are the maximum based on the provided comparator.

Type Parameters:

T - The type of objects being streamed

A - The mutable accumulation type of the reduction operation

D - The result type of the reduction operation

Parameters:

comparator - The comparator to order the items in the stream

downstream - Which collector to use to combine the results

Returns:

A new collector to provide the desired result

minAll

public static <T,A,D> Collector<T,?,D> minAll(Comparator<? super T> comparator,
                                              Collector<? super T,A,D> downstream)

A collector that returns all results that are the minimum based on the provided comparator.

Type Parameters:

T - The type of objects being streamed

A - The mutable accumulation type of the reduction operation

D - The result type of the reduction operation

Parameters:

comparator - The comparator to order the items in the stream

downstream - Which collector to use to combine the results

Returns:

A new collector to provide the desired result

toImmutableCollection

public static <T,A extends Collection<T>> Collector<T,A,Collection<T>> toImmutableCollection(Supplier<A> collectionFactory)

Type Parameters:

T - The type of the input elements

A - The accumulation type

Parameters:

collectionFactory - The collection factory

Returns:

An immutable collection

toImmutableCollection

public static <T> Collector<T,Collection<T>,Collection<T>> toImmutableCollection()

Type Parameters:

T - The type

Returns:

An immutable collection