code: func (db *BytesConnectionRedis) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error {
  	if db.closed {
  		return fmt.Errorf("watch(%v) called on a closed connection", keys)
  	}
  	db.closeCh = closeChan
  
  	return watch(db, resp, db.closeCh, nil, nil, keys...)
  }
docs: // Watch starts subscription for changes associated with the selected key. Watch events will be delivered to respChan.
  // Subscription can be canceled by StopWatch call.