code: func (pdb *BytesBrokerWatcherRedis) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error {
  	if pdb.delegate.closed {
  		return fmt.Errorf("watch(%v) called on a closed connection", keys)
  	}
  	return watch(pdb.delegate, resp, closeChan, pdb.addPrefix, pdb.trimPrefix, keys...)
  }
docs: // Watch starts subscription for changes associated with the selected key. Watch events will be delivered to respChan.