com.simiacryptus.util.io

Class BinaryChunkIterator

java.lang.Object

com.simiacryptus.util.io.BinaryChunkIterator

All Implemented Interfaces:

Iterator<byte[]>

public final class BinaryChunkIterator
extends Object
implements Iterator<byte[]>

The type Binary chunk iterator.

Constructor Summary

Constructors

Constructor and Description
BinaryChunkIterator(DataInputStream in, int recordSize) Instantiates a new Binary chunk iterator.

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
byte[]	next()
static <T> Stream<T>	toIterator(Iterator<T> iterator) To iterator stream.
Stream<byte[]>	toStream() To stream stream.
static <T> Stream<T>	toStream(Iterator<T> iterator) To stream stream.
static <T> Stream<T>	toStream(Iterator<T> iterator, int size) To stream stream.
static <T> Stream<T>	toStream(Iterator<T> iterator, int size, boolean parallel) To stream stream.

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 Detail

BinaryChunkIterator

public BinaryChunkIterator(DataInputStream in,
                           int recordSize)

Instantiates a new Binary chunk iterator.

Parameters:

in - the in

recordSize - the record size

Method Detail

toIterator

public static <T> Stream<T> toIterator(@Nonnull
                                       Iterator<T> iterator)

To iterator stream.

Type Parameters:

T - the type parameter

Parameters:

iterator - the iterator

Returns:

the stream

toStream

public static <T> Stream<T> toStream(@Nonnull
                                     Iterator<T> iterator)

To stream stream.

Type Parameters:

T - the type parameter

Parameters:

iterator - the iterator

Returns:

the stream

toStream

public static <T> Stream<T> toStream(@Nonnull
                                     Iterator<T> iterator,
                                     int size)

To stream stream.

Type Parameters:

T - the type parameter

Parameters:

iterator - the iterator

size - the size

Returns:

the stream

toStream

public static <T> Stream<T> toStream(@Nonnull
                                     Iterator<T> iterator,
                                     int size,
                                     boolean parallel)

To stream stream.

Type Parameters:

T - the type parameter

Parameters:

iterator - the iterator

size - the size

parallel - the parallel

Returns:

the stream

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<byte[]>

next

@Nonnull
public byte[] next()

Specified by:

next in interface Iterator<byte[]>

toStream

public Stream<byte[]> toStream()

To stream stream.

Returns:

the stream