Package com.github.basking2.sdsai.itrex.iterators

Class ByteBufferInputStreamIteator

java.lang.Object

com.github.basking2.sdsai.itrex.iterators.ByteBufferInputStreamIteator

All Implemented Interfaces:

Iterator<ByteBuffer>

public class ByteBufferInputStreamIteator
extends Object
implements Iterator<ByteBuffer>

And Iterator that batches and streams reads from an InputStream. When the last read() is called on the input stream returns a length less than 0, the input stream is closed. If you do not exhaust this iterator, you must close the input stream.

Constructor Summary

Constructors

Constructor	Description
ByteBufferInputStreamIteator(InputStream in)

Method Summary

Modifier and Type	Method	Description
boolean	hasNext()
ByteBuffer	next()
static final int	readOrClose(InputStream in, byte[] nextBuffer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Details

ByteBufferInputStreamIteator

public ByteBufferInputStreamIteator(InputStream in)
                             throws IOException

Throws:

IOException

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<ByteBuffer>

next

public ByteBuffer next()

Specified by:

next in interface Iterator<ByteBuffer>

readOrClose

public static final int readOrClose(InputStream in,
 byte[] nextBuffer)
                             throws IOException

Throws:

IOException