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