@patch('kombu.compat._iterconsume')
def test_iterconsume(self, _iterconsume, n='test_iterconsume'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    cs = compat.ConsumerSet(self.connection, consumers=[c])
    cs.iterconsume(limit=10, no_ack=True)
    _iterconsume.assert_called_with(c.connection, cs, True, 10)
@patch('kombu.compat._iterconsume')
def test_iterconsume(self, _iterconsume, n='test_iterconsume'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    cs = compat.ConsumerSet(self.connection, consumers=[c])
    cs.iterconsume(limit=10, no_ack=True)
    _iterconsume.assert_called_with(c.connection, cs, True, 10)