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