'BlockingChannel Channel.Flow activate and deactivate'

def test(self):

    connection = self._connect()
    ch = connection.channel()
    q_name = ('TestChannelFlow_q' + uuid.uuid1().hex)
    ch.queue_declare(q_name, auto_delete=False)
    self.addCleanup(self._connect().channel().queue_delete, q_name)
    frame = ch.queue_declare(q_name, passive=True)
    self.assertEqual(frame.method.consumer_count, 0)
    ch.basic_consume((lambda *args: None), q_name)
    frame = ch.queue_declare(q_name, passive=True)
    self.assertEqual(frame.method.consumer_count, 1)
    active = ch.flow(True)
    self.assertEqual(active, True)
    frame = ch.queue_declare(q_name, passive=True)
    self.assertEqual(frame.method.consumer_count, 1)
