code: def _x_flow_ok(self, active):
          
          args = AMQPWriter()
          args.write_bit(active)
          self._send_method((20, 21), args)
docs: Confirm a flow method
  
          Confirms to the peer that a flow command was received and
          processed.
  
          PARAMETERS:
              active: boolean
  
                  current flow setting
  
                  Confirms the setting of the processed flow method:
                  True means the peer will start sending or continue
                  to send content frames; False means it will not.