com.datumbox.framework.common.concurrency

Class StreamMethods

java.lang.Object

com.datumbox.framework.common.concurrency.StreamMethods

public class StreamMethods
extends java.lang.Object

This class contains a number of helper methods for Java 8 streams.

Constructor Summary

Constructors

Constructor and Description
StreamMethods()

Method Summary

Modifier and Type	Method and Description
static <T> java.util.stream.Stream<java.util.Map.Entry<java.lang.Integer,T>>	enumerate(java.util.stream.Stream<T> stream) Takes a stream and enumerates it (similar to Python's enumerate()) to return the item along with its position.
static <T> java.util.stream.Stream<T>	stream(java.lang.Iterable<T> iterable, boolean parallel) Converts an iterable to a stream.
static <T> java.util.stream.Stream<T>	stream(java.util.Iterator<T> iterator, boolean parallel) Converts an iterator to a stream.
static <T> java.util.stream.Stream<T>	stream(java.util.Spliterator<T> spliterator, boolean parallel) Converts an spliterator to a stream.
static <T> java.util.stream.Stream<T>	stream(java.util.stream.Stream<T> stream, boolean parallel) Converts an Stream to parallel or sequential .

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamMethods

public StreamMethods()

Method Detail

stream

public static <T> java.util.stream.Stream<T> stream(java.util.Spliterator<T> spliterator,
                                                    boolean parallel)

Converts an spliterator to a stream.

Type Parameters:

T -

Parameters:

spliterator -

parallel -

Returns:

stream

public static <T> java.util.stream.Stream<T> stream(java.lang.Iterable<T> iterable,
                                                    boolean parallel)

Converts an iterable to a stream.

Type Parameters:

T -

Parameters:

iterable -

parallel -

Returns:

stream

public static <T> java.util.stream.Stream<T> stream(java.util.stream.Stream<T> stream,
                                                    boolean parallel)

Converts an Stream to parallel or sequential .

Type Parameters:

T -

Parameters:

stream -

parallel -

Returns:

stream

public static <T> java.util.stream.Stream<T> stream(java.util.Iterator<T> iterator,
                                                    boolean parallel)

Converts an iterator to a stream.

Type Parameters:

T -

Parameters:

iterator -

parallel -

Returns:

enumerate

public static <T> java.util.stream.Stream<java.util.Map.Entry<java.lang.Integer,T>> enumerate(java.util.stream.Stream<T> stream)

Takes a stream and enumerates it (similar to Python's enumerate()) to return the item along with its position.

Type Parameters:

T -

Parameters:

stream -

Returns: