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