com.splicemachine.stream

Class Streams.LimitedStream<T>

java.lang.Object

com.splicemachine.stream.AbstractStream<T>

com.splicemachine.stream.ForwardingStream<T>

com.splicemachine.stream.Streams.LimitedStream<T>

All Implemented Interfaces:

Stream<T>, java.lang.AutoCloseable

Enclosing class:

Streams

static final class Streams.LimitedStream<T>
extends ForwardingStream<T>

Field Summary

Fields inherited from class com.splicemachine.stream.ForwardingStream

delegate

Constructor Summary

Constructors

Constructor and Description
LimitedStream(Stream<T> stream, long maxSize)

Method Summary

Modifier and Type	Method and Description
T	next()

Methods inherited from class com.splicemachine.stream.ForwardingStream

close

Methods inherited from class com.splicemachine.stream.AbstractStream

asIterator, filter, forEach, limit, transform

Methods inherited from class java.lang.Object

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

Constructor Detail

LimitedStream

public LimitedStream(Stream<T> stream,
                     long maxSize)

Method Detail

next

public T next()
       throws StreamException

Specified by:

next in interface Stream<T>

Overrides:

next in class ForwardingStream<T>

Returns:

the next element in the stream, or null if no such element exists.

Throws:

StreamException - if something breaks during the next() call.