stream.io.multi

Class AbstractMultiStream

java.lang.Object

stream.io.AbstractStream

stream.io.multi.AbstractMultiStream

All Implemented Interfaces:

MultiStream, Source, Stream

Direct Known Subclasses:

DirectoryMultiStream, MergeAllMultiStream, RandomMultiStream, SequentialMultiStream

public abstract class AbstractMultiStream
extends AbstractStream
implements MultiStream

A simple multi stream implementation.

Author:

Hendrik Blom

Field Summary

Fields

Modifier and Type	Field and Description
protected Boolean	activate
protected ActiveStream	activeWrapper
protected List<String>	additionOrder
protected org.slf4j.Logger	log
(package private) ExecutorService	pool
protected Map<String,Stream>	streams

Fields inherited from class stream.io.AbstractStream

count, id, in, limit, prefix, seqId, sequenceKey, url

Constructor Summary

Constructors

Constructor and Description
AbstractMultiStream()
AbstractMultiStream(InputStream in)
AbstractMultiStream(SourceURL url)

Method Summary

Methods

Modifier and Type	Method and Description
void	addStream(String id, Stream stream)
void	close()
Boolean	getActivate()
Map<String,Stream>	getStreams()
void	init()
void	setActivate(Boolean activate)

Methods inherited from class stream.io.AbstractStream

getId, getInputStream, getLimit, getPrefix, getSequenceKey, getUrl, read, readNext, setId, setLimit, setPrefix, setSequenceKey, setUrl

Methods inherited from class java.lang.Object

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

Methods inherited from interface stream.io.Stream

getLimit, setLimit

Methods inherited from interface stream.io.Source

getId, read, setId

Field Detail

log

protected org.slf4j.Logger log

additionOrder

protected List<String> additionOrder

streams

protected Map<String,Stream> streams

activate

protected Boolean activate

activeWrapper

protected ActiveStream activeWrapper

pool

ExecutorService pool

Constructor Detail

AbstractMultiStream

public AbstractMultiStream(SourceURL url)

AbstractMultiStream

public AbstractMultiStream(InputStream in)

AbstractMultiStream

public AbstractMultiStream()

Method Detail

getActivate

public Boolean getActivate()

setActivate

public void setActivate(Boolean activate)

addStream

public void addStream(String id,
             Stream stream)

Specified by:

addStream in interface MultiStream

getStreams

public Map<String,Stream> getStreams()

Specified by:

getStreams in interface MultiStream

init

public void init()
          throws Exception

Specified by:

init in interface Source

Overrides:

init in class AbstractStream

Throws:

Exception

See Also:

Source.init()

close

public void close()
           throws Exception

Specified by:

close in interface Source

Overrides:

close in class AbstractStream

Throws:

Exception