(sock)
| 677 | server_side_aborted = False |
| 678 | |
| 679 | def server(sock): |
| 680 | nonlocal server_side_aborted |
| 681 | try: |
| 682 | sock.recv_all(1024 * 1024) |
| 683 | except ConnectionAbortedError: |
| 684 | server_side_aborted = True |
| 685 | finally: |
| 686 | sock.close() |
| 687 | |
| 688 | async def client(addr): |
| 689 | await asyncio.wait_for( |