package pathfinder;

import java.util.ArrayList;
import java.util.List;

public class SeMaEmulator<P> implements Runnable {
	private List<ChannelSimulator<P>> csList;
	
	public SeMaEmulator(){
		csList = new ArrayList<ChannelSimulator<P>>();
	}

	public ChannelSimulator<P> addChannelSimulator(ChannelSimulator<P> cs){
		csList.add(cs);
		return cs;
	}

	public void run(){
		int i=0;
		P packet;
		ChannelSimulator<P> cs = csList.get(1);

		/* Main Loop */
		while(true){
			packet=cs.read();
			i = (i+1)%csList.size();
			cs = csList.get(i+1);
			if (packet!=null) cs.write(packet);
		}
	}
	
}