}); } setJoiner(ROUND_ROBIN(2*GENERATE_BLOCKING)); }
	public void init() {	  int i;	  setSplitter(NULL());	  for(i=0; i<numChannels; i+=GENERATE_BLOCKING) {	    //this was within a pipeline; i don't think	    //it needed to be.  - cll	    add(new SplitJoin(i) {		SplitJoin(int i) {super(i); }		public void init(int i) {		  setSplitter(NULL());		  for (int k=0; k<GENERATE_BLOCKING; k++) {		    add(new Pipeline(i+k) {			Pipeline(int i) {super(i);}			public void init(int i) {			  add(new InputGenerate(i,						numSamples,						targetBeam,						targetSample,						cfarThreshold));			  add(new BeamFirFilter(numCoarseFilterTaps,						numSamples,						coarseDecimationRatio));			  add(new BeamFirFilter(numFineFilterTaps,						numPostDec1,						fineDecimationRatio));			}		      });		  }		  setJoiner(ROUND_ROBIN(2));		}	      });	  }	  setJoiner(ROUND_ROBIN(2*GENERATE_BLOCKING));	}