org.n52.janmayen.stream

Class Streams

java.lang.Object

org.n52.janmayen.stream.Streams

public final class Streams
extends Object

Utility functions for Stream.

Method Summary

Modifier and Type	Method and Description
static IntStream	reverseRange(int from, int to) Returns a sequential reverse-ordered IntStream from from (inclusive) to to (exclusive) by an incremental step of 1.
static IntStream	reverseRangeClosed(int from, int to) Returns a sequential reverse-ordered IntStream from from (inclusive) to to (inclusive) by an incremental step of 1.
static DoubleStream	reverseStream(double[] array) Returns a reversed stream of the array values.
static DoubleStream	reverseStream(double[] array, int startInclusive, int endInclusive) Returns a reversed stream of the array values.
static IntStream	reverseStream(int[] array) Returns a reversed stream of the array values.
static IntStream	reverseStream(int[] array, int startInclusive, int endInclusive) Returns a reversed stream of the array values.
static LongStream	reverseStream(long[] array) Returns a reversed stream of the array values.
static LongStream	reverseStream(long[] array, int startInclusive, int endInclusive) Returns a reversed stream of the array values.
static <T> Stream<T>	reverseStream(T[] array) Returns a reversed stream of the array values.
static <T> Stream<T>	reverseStream(T[] array, int startInclusive, int endInclusive) Returns a reversed stream of the array values.
static <T> Stream<T>	stream(Collection<T> collection) Factory function for creating a Stream from a Collection.
static DoubleStream	stream(double[] array) Factory function for creating a Stream from an array.
static <T> Stream<T>	stream(Enumeration<T> enumeration) Factory function for creating a Stream from an Enumeration.
static IntStream	stream(int[] array) Factory function for creating a Stream from an array.
static <T> Stream<T>	stream(Iterable<T> iterable) Factory function for creating a Stream from an Iterable.
static <T> Stream<T>	stream(Iterator<T> iterator) Factory function for creating a Stream from an Iterator.
static LongStream	stream(long[] array) Factory function for creating a Stream from an array.
static <T> Stream<T>	stream(T[] array) Factory function for creating a Stream from an array.
static <T> BinaryOperator<T>	throwingMerger() Creates a BinaryOperator that throws an IllegalStateException if invoked.
static <T> BinaryOperator<T>	throwingMerger(BiFunction<T,T,? extends RuntimeException> exceptionSupplier) Creates a BinaryOperator that throws an exception if invoked.
static <T> BinaryOperator<T>	throwingMerger(Supplier<? extends RuntimeException> exceptionSupplier) Creates a BinaryOperator that throws an exception if invoked.

Methods inherited from class java.lang.Object

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

Method Detail

reverseRangeClosed

public static IntStream reverseRangeClosed(int from,
                                           int to)

Returns a sequential reverse-ordered IntStream from from (inclusive) to to (inclusive) by an incremental step of 1.

Parameters:

from - the inclusive lower bound

to - the inclusive upper bound

Returns:

the reverse range

See Also:

IntStream.range(int, int)

reverseRange

public static IntStream reverseRange(int from,
                                     int to)

Returns a sequential reverse-ordered IntStream from from (inclusive) to to (exclusive) by an incremental step of 1.

Parameters:

from - the inclusive lower bound

to - the exclusive upper bound

Returns:

the reverse range

See Also:

IntStream.range(int, int)

reverseStream

public static <T> Stream<T> reverseStream(T[] array,
                                          int startInclusive,
                                          int endInclusive)

Returns a reversed stream of the array values. Note that the index boundaries are given using the original order.

Type Parameters:

T - the element type of the stream

Parameters:

array - the array

startInclusive - the lowest index (i.e. the last element to return)

endInclusive - index immediately past the highest index (i.e. the index after the first returned value

Returns:

the reversed stream

reverseStream

public static LongStream reverseStream(long[] array,
                                       int startInclusive,
                                       int endInclusive)

Returns a reversed stream of the array values. Note that the index boundaries are given using the original order.

Parameters:

array - the array

startInclusive - the lowest index (i.e. the last element to return)

endInclusive - index immediately past the highest index (i.e. the index after the first returned value

Returns:

the reversed stream

reverseStream

public static IntStream reverseStream(int[] array,
                                      int startInclusive,
                                      int endInclusive)

Returns a reversed stream of the array values. Note that the index boundaries are given using the original order.

Parameters:

array - the array

startInclusive - the lowest index (i.e. the last element to return)

endInclusive - index immediately past the highest index (i.e. the index after the first returned value

Returns:

the reversed stream

reverseStream

public static DoubleStream reverseStream(double[] array,
                                         int startInclusive,
                                         int endInclusive)

Returns a reversed stream of the array values. Note that the index boundaries are given using the original order.

Parameters:

array - the array

startInclusive - the lowest index (i.e. the last element to return)

endInclusive - index immediately past the highest index (i.e. the index after the first returned value

Returns:

the reversed stream

reverseStream

public static <T> Stream<T> reverseStream(T[] array)

Returns a reversed stream of the array values.

Type Parameters:

T - the element type of the stream

Parameters:

array - the array

Returns:

the reversed stream

reverseStream

public static LongStream reverseStream(long[] array)

Returns a reversed stream of the array values.

Parameters:

array - the array

Returns:

the reversed stream

reverseStream

public static IntStream reverseStream(int[] array)

Returns a reversed stream of the array values.

Parameters:

array - the array

Returns:

the reversed stream

reverseStream

public static DoubleStream reverseStream(double[] array)

Returns a reversed stream of the array values.

Parameters:

array - the array

Returns:

the reversed stream

stream

public static <T> Stream<T> stream(Enumeration<T> enumeration)

Factory function for creating a Stream from an Enumeration.

Type Parameters:

T - the element type

Parameters:

enumeration - the enumeration

Returns:

the stream

stream

public static <T> Stream<T> stream(Iterator<T> iterator)

Factory function for creating a Stream from an Iterator.

Type Parameters:

T - the element type

Parameters:

iterator - the iterator

Returns:

the stream

stream

public static <T> Stream<T> stream(Iterable<T> iterable)

Factory function for creating a Stream from an Iterable.

Type Parameters:

T - the element type

Parameters:

iterable - the iterable

Returns:

the stream

stream

public static <T> Stream<T> stream(T[] array)

Factory function for creating a Stream from an array.

Type Parameters:

T - the element type

Parameters:

array - the array

Returns:

the stream

stream

public static IntStream stream(int[] array)

Factory function for creating a Stream from an array.

Parameters:

array - the array

Returns:

the stream

stream

public static LongStream stream(long[] array)

Factory function for creating a Stream from an array.

Parameters:

array - the array

Returns:

the stream

stream

public static DoubleStream stream(double[] array)

Factory function for creating a Stream from an array.

Parameters:

array - the array

Returns:

the stream

stream

public static <T> Stream<T> stream(Collection<T> collection)

Factory function for creating a Stream from a Collection.

Type Parameters:

T - the element type

Parameters:

collection - the collection

Returns:

the stream

throwingMerger

public static <T> BinaryOperator<T> throwingMerger(Supplier<? extends RuntimeException> exceptionSupplier)

Creates a BinaryOperator that throws an exception if invoked.

Type Parameters:

T - the operators input and result type

Parameters:

exceptionSupplier - the exception factory

Returns:

the operator

See Also:

Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier)

throwingMerger

public static <T> BinaryOperator<T> throwingMerger()

Creates a BinaryOperator that throws an IllegalStateException if invoked.

Type Parameters:

T - the operators input and result type

Returns:

the operator

See Also:

Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier)

throwingMerger

public static <T> BinaryOperator<T> throwingMerger(BiFunction<T,T,? extends RuntimeException> exceptionSupplier)

Creates a BinaryOperator that throws an exception if invoked.

Type Parameters:

T - the operators input and result type

Parameters:

exceptionSupplier - the exception factory

Returns:

the operator

See Also:

Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator), Collectors.toConcurrentMap(java.util.function.Function, java.util.function.Function, java.util.function.BinaryOperator, java.util.function.Supplier)