Package com.tagtraum.audiokern.audioprocessor

Class FloatCollector

java.lang.Object

com.tagtraum.jipes.AbstractSignalProcessor<Float,float[]>

com.tagtraum.audiokern.audioprocessor.FloatCollector

All Implemented Interfaces:

SignalProcessor<Float,float[]>, SignalPullProcessor<Float,float[]>, SignalSource<float[]>

public class FloatCollector
extends AbstractSignalProcessor<Float,float[]>

Collects Floats in a float array. If you'd like to use this class, but only have a more complex object to work with, use a Aggregate to convert your complex object to a float before using this collector.
In push mode, downstream processors are handed the array when flush() is called. Suitable downstream processors include Aggregate.
In pull mode, the upstream generator is read completely, its elements are converted to floats and collected in an array that is then returned when read() is called.

Author:

Hendrik Schreiber

See Also:

ListCollector, Aggregate

Field Summary

Fields inherited from class com.tagtraum.jipes.AbstractSignalProcessor

lastOut, signalProcessorSupport

Constructor Summary

Constructors

Constructor	Description
FloatCollector()
FloatCollector(Object id)

Method Summary

Modifier and Type	Method	Description
void	flush()
float[]	getOutput()
void	process(Float element)
protected float[]	processNext(Float element)
float[]	read()
void	reset()
String	toString()

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, wait, wait, wait

Constructor Detail

FloatCollector

public FloatCollector()

FloatCollector

public FloatCollector(Object id)

Method Detail

processNext

protected float[] processNext(Float element)
                       throws IOException

Specified by:

processNext in class AbstractSignalProcessor<Float,float[]>

Throws:

IOException

reset

public void reset()

Specified by:

reset in interface SignalSource<float[]>

Overrides:

reset in class AbstractSignalProcessor<Float,float[]>

process

public void process(Float element)
             throws IOException

Specified by:

process in interface SignalProcessor<Float,float[]>

Overrides:

process in class AbstractSignalProcessor<Float,float[]>

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface SignalProcessor<Float,float[]>

Overrides:

flush in class AbstractSignalProcessor<Float,float[]>

Throws:

IOException

getOutput

public float[] getOutput()
                  throws IOException

Specified by:

getOutput in interface SignalProcessor<Float,float[]>

Overrides:

getOutput in class AbstractSignalProcessor<Float,float[]>

Throws:

IOException

read

public float[] read()
             throws IOException

Specified by:

read in interface SignalSource<float[]>

Overrides:

read in class AbstractSignalProcessor<Float,float[]>

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object