com.blazegraph.gremlin.util

Class Streams

java.lang.Object

com.blazegraph.gremlin.util.Streams

public class Streams
extends Object

Additional Java 8 stream helpers.

Author:

mikepersonick

Constructor Summary

Constructors

Constructor and Description
Streams()

Method Summary

Modifier and Type	Method and Description
static <T> Stream<T>	of(Iterator<T> it) Obtain a Java 8 stream from an iterator.

Methods inherited from class java.lang.Object

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

Constructor Detail

Streams

public Streams()

Method Detail

of

public static final <T> Stream<T> of(Iterator<T> it)

Obtain a Java 8 stream from an iterator. If the iterator happens to implement AutoCloseable (e.g. CloseableIterator), the stream's onClose behavior will close the iterator. Thus it is important to always close the returned stream, or use within a try-with-resources:

 
 try (Stream<Object> s = Streams.of(it)) {
     // do something with s
 } // auto-close