@Override
    synchronized public void close() {
      if (!myCollectingStopped) {
        myCollectingStopped = true;
        notifyFinished();
      }
    }
@Override
    synchronized public void close()