(self)
| 981 | |
| 982 | class TestIOStreamStartTLS(AsyncTestCase): |
| 983 | def setUp(self): |
| 984 | try: |
| 985 | super().setUp() |
| 986 | self.listener, self.port = bind_unused_port() |
| 987 | self.server_stream = None |
| 988 | self.server_accepted = Future() # type: Future[None] |
| 989 | netutil.add_accept_handler(self.listener, self.accept) |
| 990 | self.client_stream = IOStream( |
| 991 | socket.socket() |
| 992 | ) # type: typing.Optional[IOStream] |
| 993 | self.io_loop.add_future( |
| 994 | self.client_stream.connect(("127.0.0.1", self.port)), self.stop |
| 995 | ) |
| 996 | self.wait() |
| 997 | self.io_loop.add_future(self.server_accepted, self.stop) |
| 998 | self.wait() |
| 999 | except Exception as e: |
| 1000 | print(e) |
| 1001 | raise |
| 1002 | |
| 1003 | def tearDown(self): |
| 1004 | if self.server_stream is not None: |
nothing calls this directly
no test coverage detected