(self)
| 320 | self.assertTrue(self.streams.pop("c").closed) |
| 321 | |
| 322 | def test_all_fail(self): |
| 323 | conn, future = self.start_connect(self.addrinfo) |
| 324 | self.assert_pending((AF1, "a")) |
| 325 | conn.on_timeout() |
| 326 | self.assert_pending((AF1, "a"), (AF2, "c")) |
| 327 | self.resolve_connect(AF2, "c", False) |
| 328 | self.assert_pending((AF1, "a"), (AF2, "d")) |
| 329 | self.resolve_connect(AF2, "d", False) |
| 330 | # one queue is now empty |
| 331 | self.assert_pending((AF1, "a")) |
| 332 | self.resolve_connect(AF1, "a", False) |
| 333 | self.assert_pending((AF1, "b")) |
| 334 | self.assertFalse(future.done()) |
| 335 | self.resolve_connect(AF1, "b", False) |
| 336 | self.assertRaises(IOError, future.result) |
| 337 | |
| 338 | def test_one_family_timeout_after_connect_timeout(self): |
| 339 | conn, future = self.start_connect([(AF1, "a"), (AF1, "b")]) |
nothing calls this directly
no test coverage detected