if (!obj.processed()) return;
  public void consume(NumberedObject obj) {    if (asynchronousWrite)      consumeForDumper(obj);    else {      try {	CountsTable currCounts = (CountsTable)obj.get();	if (useCountThreshold)	  currCounts.removeItemsBelow(countThreshold);	EventCountsWriter.outputEvents(currCounts, out);	out.flush();      }      catch (IOException ioe) {	System.err.println(className + ": error outputting events: " + ioe);      }    }  }