code: public void clear() {
      lock.lock();
      try {
        currentControlTuple = null;
        currentDataTuple = null;
  
        outQueue.clear();
      } finally {
        lock.unlock();
      }
    }
docs: Clean the internal state of OutgoingTupleCollection