(self, addrinfo)
| 242 | self.assertTrue(stream.closed) |
| 243 | |
| 244 | def start_connect(self, addrinfo): |
| 245 | conn = _Connector(addrinfo, self.create_stream) |
| 246 | # Give it a huge timeout; we'll trigger timeouts manually. |
| 247 | future = conn.start(3600, connect_timeout=self.io_loop.time() + 3600) |
| 248 | return conn, future |
| 249 | |
| 250 | def test_immediate_success(self): |
| 251 | conn, future = self.start_connect(self.addrinfo) |
no test coverage detected