com.chemaxon.overlap.cli.util

Class MultiInputCloseableIterator<T,CI extends Iterator<T> & Closeable>

java.lang.Object

com.google.common.collect.UnmodifiableIterator<T>

com.google.common.collect.AbstractIterator<T>

com.chemaxon.overlap.cli.util.MultiInputCloseableIterator<T,CI>

Type Parameters:

T - Iterated entities

CI - Underlying Closeable Iterator type

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<T>

public final class MultiInputCloseableIterator<T,CI extends Iterator<T> & Closeable>
extends AbstractIterator<T>
implements Closeable

Iterates entities from multiple InputStream sources.

Constructor Summary

Constructors

Constructor and Description
MultiInputCloseableIterator(Iterable<Supplier<InputStream>> inputs, Function<InputStream,CI> iterateInputStream) Construct.

Method Summary

Modifier and Type	Method and Description
void	close()
protected T	computeNext()
static Function<InputStream,CloseableLineIterator>	iterateLines() Iterate lines of an InputStream.
static Function<InputStream,StructureRecordIterator>	iterateStructureRecords(String opts) Create StructureRecordIterator form an InputStream.

Methods inherited from class com.google.common.collect.AbstractIterator

endOfData, hasNext, next, peek

Methods inherited from class com.google.common.collect.UnmodifiableIterator

remove

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

Constructor Detail

MultiInputCloseableIterator

public MultiInputCloseableIterator(Iterable<Supplier<InputStream>> inputs,
                                   Function<InputStream,CI> iterateInputStream)

Construct. Accessing/opening of the InputStreams is done only on the first read after closing the previous ones.

Parameters:

inputs - Inputs.

iterateInputStream - Factory for create a Closeable Iterator for an InputStream

Method Detail

iterateLines

public static Function<InputStream,CloseableLineIterator> iterateLines()

Iterate lines of an InputStream.

Returns:

Function to iterate lines

iterateStructureRecords

public static Function<InputStream,StructureRecordIterator> iterateStructureRecords(String opts)

Create StructureRecordIterator form an InputStream.

Parameters:

opts - Options to pass to the underlying MFileFormatUtil#createRecordReader(java.io.InputStream, java.lang.String)

Returns:

computeNext

protected T computeNext()

Specified by:

computeNext in class AbstractIterator<T>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException