code: def _notify(self, topic, **kwargs):
          
          for cb in self._connects.get(topic, []):
              try:
                  cb(**kwargs)
              except Exception:
                  if self._debug:
                      traceback.print_exc()
docs: Invokes callbacks for an event topic.
  
          @param topic: String event name
          @type topic: str
          @param kwargs: Values associated with the event
          @type kwargs: dict