def _cb_flow(self, method):
        args = method.args
        self.active = args.read_bit()
        self._send_flow_ok(self.active)
Enable/disable flow from peer
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel._cb_flow