/**
 * Simple parameterized delay filter.
 **/
import streamit.*;

public class DelayPipeline extends Pipeline {
    public DelayPipeline(int delay) {
	super(delay);
    }
    public void init(int delay) {
	// basically, just add a bunch of unit delay filters
	for (int i=0; i<delay; i++) {
	    this.add(new Delay());
	}
    }
}



/** Character Unit delay **/
class Delay extends Filter {
    float state;
    public void init() {
	// initial state of delay is 0
	this.state = 0.0f;
	input = new Channel(Float.TYPE,1);
	output = new Channel(Float.TYPE,1);
    }
    public void work() {
	// push out the state and then update it with the input
	// from the channel
	output.pushFloat(this.state);
	this.state = input.popFloat();
    }
}