code: def get_watcher(self):
          
          if not self.watching:
              raise StopIteration()
          return self.client.eternal_watch(self.prefix, recursive=True)
docs: Return a etcd watching generator which yields events as they happen.