def test__iter__(self, n='test__iter__'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    c.iterqueue = Mock()
    c.__iter__()
    c.iterqueue.assert_called_with(infinite=True)
def test__iter__(self, n='test__iter__'):
    c = compat.Consumer(self.connection, queue=n, exchange=n)
    c.iterqueue = Mock()
    c.__iter__()
    c.iterqueue.assert_called_with(infinite=True)