code: func (sr *SimpleRedis) watch(done chan struct{}) {
  	sr.log.Info("==> Redis DB watcher started")
  
  	var count int8
  
  	for {
  		select {
  		case r, ok := <-sr.respChan:
  			count++
  			if !ok {
  				sr.log.Info("==> Redis DB watcher closed")
  				return
  			}
  			switch r.GetChangeType() {
  			case datasync.Put:
  				sr.log.Debugf("==> Redis watcher: received 'put' event: key: %s, value: %s", r.GetKey(), string(r.GetValue()))
  			case datasync.Delete:
  				sr.log.Debugf("==> Redis watcher: received 'delete' event: key: %s", r.GetKey())
  			}
  			if count == 12 {
  				sr.log.Info("All expected events were received by watcher")
  				done <- struct{}{}
  			}
  		}
  	}
  }
docs: // watch redis database for all the keys/values put during the example