

def test_get_connected_socket(self):
    s = self.conn.get_connected_socket()
    self.assertEqual(s, self.MockCreateConn())

dataset/ETHPy150Open dpkp/kafka-python/test/test_conn_legacy.py ConnTest.test_get_connected_socket/original