code: def register_watcher(self, event_type, callback, register_timeout=None):
          
          self._push_watchers[event_type].add(callback)
          self.wait_for_response(
              RegisterMessage(event_list=[event_type]),
              timeout=register_timeout)
docs: Register a callback for a given event type.