(addr)
| 320 | sock.close() |
| 321 | |
| 322 | async def client(addr): |
| 323 | reader, writer = await asyncio.open_connection( |
| 324 | *addr, |
| 325 | ssl=client_sslctx, |
| 326 | server_hostname='', |
| 327 | ssl_handshake_timeout=HANDSHAKE_TIMEOUT) |
| 328 | |
| 329 | writer.write(A_DATA) |
| 330 | self.assertEqual(await reader.readexactly(2), b'OK') |
| 331 | |
| 332 | writer.write(B_DATA) |
| 333 | self.assertEqual(await reader.readexactly(4), b'SPAM') |
| 334 | |
| 335 | nonlocal CNT |
| 336 | CNT += 1 |
| 337 | |
| 338 | writer.close() |
| 339 | await self.wait_closed(writer) |
| 340 | |
| 341 | async def client_sock(addr): |
| 342 | sock = socket.socket() |
no test coverage detected