code: func (b *ProtoWatcherWrapper) Watch(respChan func(datasync.ProtoWatchResp), closeChan chan string, keys ...string) error {
  	return b.ProtoWatcher.Watch(func(resp datasync.ProtoWatchResp) {
  		respChan(&ProtoWatchRespWrapper{
  			ProtoWatchResp: resp,
  			ProtoKeyValWrapper: ProtoKeyValWrapper{
  				ProtoKeyVal: resp,
  				decryptData: b.decryptData,
  			},
  		})
  	}, closeChan, keys...)
  }
docs: // Watch starts subscription for changes associated with the selected keys.
  // Watch events will be delivered to callback (not channel) <respChan>.
  // Channel <closeChan> can be used to close watching on respective key