(addr)
| 322 | self.on_eof.set_result(True) |
| 323 | |
| 324 | async def client(addr): |
| 325 | await asyncio.sleep(0.5) |
| 326 | |
| 327 | on_data = self.loop.create_future() |
| 328 | on_eof = self.loop.create_future() |
| 329 | |
| 330 | tr, proto = await self.loop.create_connection( |
| 331 | lambda: ClientProto(on_data, on_eof), *addr) |
| 332 | |
| 333 | tr.write(HELLO_MSG) |
| 334 | new_tr = await self.loop.start_tls(tr, proto, client_context) |
| 335 | |
| 336 | self.assertEqual(await on_data, b'O') |
| 337 | new_tr.write(HELLO_MSG) |
| 338 | await on_eof |
| 339 | |
| 340 | new_tr.close() |
| 341 | |
| 342 | with self.tcp_server(serve, timeout=self.TIMEOUT) as srv: |
| 343 | self.loop.run_until_complete( |
nothing calls this directly
no test coverage detected