Package com.datumbox.framework.common.concurrency

Class StreamMethods

java.lang.Object

com.datumbox.framework.common.concurrency.StreamMethods

public class StreamMethods
extends Object

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

Author:

Vasilis Vryniotis

Constructor Summary

Constructors

Constructor	Description
StreamMethods()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamMethods

public StreamMethods()

Method Detail

stream

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

Converts an spliterator to a stream.

Type Parameters:

T -

Parameters:

spliterator -

parallel -

Returns:

stream

public static <T> Stream<T> stream(Iterable<T> iterable,
                                   boolean parallel)

Converts an iterable to a stream.

Type Parameters:

T -

Parameters:

iterable -

parallel -

Returns:

stream

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

Converts an Stream to parallel or sequential .

Type Parameters:

T -

Parameters:

stream -

parallel -

Returns:

stream

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

Converts an iterator to a stream.

Type Parameters:

T -

Parameters:

iterator -

parallel -

Returns:

enumerate

public static <T> Stream<Map.Entry<Integer,T>> enumerate(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: