| 1149 | self.assertEqual(topology._servers, {}) |
| 1150 | |
| 1151 | def test_close_closes_sockets(self): |
| 1152 | client = self.rs_client() |
| 1153 | client.test.test.find_one() |
| 1154 | topology = client._topology |
| 1155 | client.close() |
| 1156 | for server in topology._servers.values(): |
| 1157 | self.assertFalse(server._pool.conns) |
| 1158 | self.assertTrue(server._monitor._executor._stopped) |
| 1159 | self.assertTrue(server._monitor._rtt_monitor._executor._stopped) |
| 1160 | self.assertFalse(server._monitor._pool.conns) |
| 1161 | self.assertFalse(server._monitor._rtt_monitor._pool.conns) |
| 1162 | |
| 1163 | def test_bad_uri(self): |
| 1164 | with self.assertRaises(InvalidURI): |