def add_rate_limit(self, limiter):
        """ Add a RateLimit to the connection """
        if limiter not in self.rate_limiters:
            self.subscribe('capacity', limiter.on_capacity)
            self.rate_limiters.append(limiter)
Add a RateLimit to the connection