(self)
| 946 | |
| 947 | class TestIOStreamStartTLS(AsyncTestCase): |
| 948 | def setUp(self): |
| 949 | try: |
| 950 | super().setUp() |
| 951 | self.listener, self.port = bind_unused_port() |
| 952 | self.server_stream = None |
| 953 | self.server_accepted = Future() # type: Future[None] |
| 954 | netutil.add_accept_handler(self.listener, self.accept) |
| 955 | self.client_stream = IOStream( |
| 956 | socket.socket() |
| 957 | ) # type: typing.Optional[IOStream] |
| 958 | self.io_loop.add_future( |
| 959 | self.client_stream.connect(("127.0.0.1", self.port)), self.stop |
| 960 | ) |
| 961 | self.wait() |
| 962 | self.io_loop.add_future(self.server_accepted, self.stop) |
| 963 | self.wait() |
| 964 | except Exception as e: |
| 965 | print(e) |
| 966 | raise |
| 967 | |
| 968 | def tearDown(self): |
| 969 | if self.server_stream is not None: |
nothing calls this directly
no test coverage detected