code: func NewWatchUpdateQueue() WatchUpdateQueue {
  	mtx := &sync.Mutex{}
  	return &watchQueue{
  		m:       mtx,
  		cv:      sync.NewCond(mtx),
  		updates: list.New()}
  }
docs: // NewWatchUpdateQueue returns WatchUpdateQueue