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