code: func (q *TransmitLimitedQueue) Reset() {
  	q.mu.Lock()
  	defer q.mu.Unlock()
  
  	q.walkReadOnlyLocked(false, func(cur *limitedBroadcast) bool {
  		cur.b.Finished()
  		return true
  	})
  
  	q.tq = nil
  	q.tm = nil
  	q.idGen = 0
  }
docs: // Reset clears all the queued messages. Should only be used for tests.