code: func NewWatchUpdateQueue() WatchUpdateQueue {
  	mtx := &sync.Mutex{}
  	return &watchQueue{
  		m:       mtx,
  		cv:      sync.NewCond(mtx),
  		updates: make([]*watchUpdate, 0)}
  }
docs: // NewWatchUpdateQueue returns an instance of WatchUpdateQueue