public synchronized void channelDone(int channel){
  if (!chBusy[channel])   throw new IllegalStateException("channel " + channel + " is not busy");
  chBusy[channel]=false;
  gate.release();
}

public synchronized void channelDone ( int channel ) { if ( ! chBusy [ channel ] ) throw new IllegalStateException ( "channel " + channel + " is not busy" ) ; chBusy [ channel ] = false ; gate . release ( ) ; }
signal that the channel is done processing the splitter supplied tuple .
