Package com.tagtraum.audiokern.audioprocessor

Class ListCollector<E>

java.lang.Object

com.tagtraum.jipes.AbstractSignalProcessor<E,List<E>>

com.tagtraum.audiokern.audioprocessor.ListCollector<E>

All Implemented Interfaces:

SignalProcessor<E,List<E>>, SignalPullProcessor<E,List<E>>, SignalSource<List<E>>

public class ListCollector<E>
extends AbstractSignalProcessor<E,List<E>>

Collects objects in a list.
In push mode, downstream processors are handed the list when flush() is called. In pull mode, the upstream generator is read completely, it's elements are collected in a list that is then returned when read() is called.

Author:

Hendrik Schreiber

See Also:

FloatCollector

Field Summary

Fields inherited from class com.tagtraum.jipes.AbstractSignalProcessor

lastOut, signalProcessorSupport

Constructor Summary

Constructors

Constructor	Description
ListCollector()

Method Summary

Modifier and Type	Method	Description
void	flush()
List<E>	getOutput()
void	process(E element)
protected List<E>	processNext(E element)
List<E>	read()
void	reset()

Methods inherited from class com.tagtraum.jipes.AbstractSignalProcessor

connectTo, connectTo, connectTo, disconnectFrom, getConnectedProcessors, getConnectedSource, getId, setId

Methods inherited from class java.lang.Object

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

Constructor Detail

ListCollector

public ListCollector()

Method Detail

processNext

protected List<E> processNext(E element)
                       throws IOException

Specified by:

processNext in class AbstractSignalProcessor<E,List<E>>

Throws:

IOException

reset

public void reset()

Specified by:

reset in interface SignalSource<E>

Overrides:

reset in class AbstractSignalProcessor<E,List<E>>

process

public void process(E element)
             throws IOException

Specified by:

process in interface SignalProcessor<E,List<E>>

Overrides:

process in class AbstractSignalProcessor<E,List<E>>

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface SignalProcessor<E,List<E>>

Overrides:

flush in class AbstractSignalProcessor<E,List<E>>

Throws:

IOException

getOutput

public List<E> getOutput()
                  throws IOException

Specified by:

getOutput in interface SignalProcessor<E,List<E>>

Overrides:

getOutput in class AbstractSignalProcessor<E,List<E>>

Throws:

IOException

read

public List<E> read()
             throws IOException

Specified by:

read in interface SignalSource<E>

Overrides:

read in class AbstractSignalProcessor<E,List<E>>

Throws:

IOException