

def _set_flow_limits(self, _, exc=None):
    if (not exc):
        self._transport.set_write_buffer_limits(self._low_limit, self._high_limit)

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