docs: def register(self, subscriber):
          """Register a new subscriber. This method should be invoked by
          listeners to start receiving messages.
  
          """
          assert isinstance(subscriber, RequestHandler)
          logger.debug('New subscriber')
          self.subscribers.add(subscriber)