import asyncio


async def main() -> None:
    reader, writer = await asyncio.open_connection(
        host="127.0.0.1",
        port=8765,
    )

    print("Connected")

    try:
        await asyncio.sleep(10)
    finally:
        writer.close()
        await writer.wait_closed()
        print("Disconnected")


asyncio.run(main())