

def __init__(self, low_limit=None, high_limit=None, **kw):
    self._low_limit = low_limit
    self._high_limit = high_limit
    self.bind_event('connection_made', self._set_flow_limits)
    self.bind_event('connection_lost', self._wakeup_waiter)
    self.bind_event('after_write', self._make_write_waiter)

dataset/ETHPy150Open quantmind/pulsar/pulsar/async/mixins.py FlowControl.__init__/original