def test_consume_in_threads(self):
    self.conn.servers = [mock.Mock(), mock.Mock()]
    servs = self.conn.consume_in_threads()
    for serv in self.conn.servers:
        serv.start.assert_called_once_with()
    self.assertEqual(servs, self.conn.servers)
def test_consume_in_threads(self):
    self.conn.servers = [mock.Mock(), mock.Mock()]
    servs = self.conn.consume_in_threads()
    for serv in self.conn.servers:
        serv.start.assert_called_once_with()
    self.assertEqual(servs, self.conn.servers)