code: func ToChanProto(respCh chan datasync.ProtoWatchResp, opts ...interface{}) func(dto datasync.ProtoWatchResp) {
  	return func(dto datasync.ProtoWatchResp) {
  		select {
  		case respCh <- dto:
  			// success
  		case <-time.After(datasync.DefaultNotifTimeout):
  			logging.DefaultLogger.Warn("Unable to deliver notification")
  		}
  	}
  }
docs: // ToChanProto creates a callback that can be passed to the Watch function
  // in order to receive JSON/protobuf-formatted notifications through a channel.
  // If the notification cannot be delivered until timeout, it is dropped.