(client_reader, client_writer)
| 824 | # gh-142352: test start_tls() with buffered data |
| 825 | |
| 826 | async def server_handler(client_reader, client_writer): |
| 827 | # Wait for TLS ClientHello to be buffered before start_tls(). |
| 828 | await client_reader._wait_for_data('test_start_tls_buffered_data'), |
| 829 | self.assertTrue(client_reader._buffer) |
| 830 | await client_writer.start_tls(test_utils.simple_server_sslcontext()) |
| 831 | |
| 832 | line = await client_reader.readline() |
| 833 | self.assertEqual(line, b"ping\n") |
| 834 | client_writer.write(b"pong\n") |
| 835 | await client_writer.drain() |
| 836 | client_writer.close() |
| 837 | await client_writer.wait_closed() |
| 838 | |
| 839 | async def client(addr): |
| 840 | reader, writer = await asyncio.open_connection(*addr) |
nothing calls this directly
no test coverage detected