class ClaudeSDKClient:
    def __init__(
        self,
        options: ClaudeAgentOptions | None = None,
        transport: Transport | None = None,
    )

async def connect(self, prompt: str | AsyncIterable[dict] | None = None) -> None
async def disconnect(self) -> None
async def __aenter__(self) -> ClaudeSDKClient
async def __aexit__(...) -> bool

async def query(self, prompt: str | AsyncIterable[dict], session_id: str = "default") -> None
async def receive_messages(self) -> AsyncIterator[Message]
async def receive_response(self) -> AsyncIterator[Message]  # 到 ResultMessage 为止

async def interrupt(self) -> None
async def set_permission_mode(self, mode: PermissionMode) -> None
async def set_model(self, model: str | None = None) -> None
async def rewind_files(self, user_message_id: str) -> None
async def reconnect_mcp_server(self, server_name: str) -> None
async def toggle_mcp_server(self, server_name: str, enabled: bool) -> None
async def stop_task(self, task_id: str) -> None

async def get_mcp_status(self) -> McpStatusResponse
async def get_context_usage(self) -> ContextUsageResponse
async def get_server_info(self) -> dict[str, Any] | None

from claude_agent_sdk import ClaudeSDKClient, ClaudeAgentOptions, AssistantMessage, TextBlock

async def main():
    options = ClaudeAgentOptions(allowed_tools=["Read", "Bash"])

    async with ClaudeSDKClient(options) as client:
        await client.query("列出当前目录的文件")
        async for msg in client.receive_response():
            if isinstance(msg, AssistantMessage):
                for block in msg.content:
                    if isinstance(block, TextBlock):
                        print(block.text)

client = ClaudeSDKClient(options)
try:
    await client.connect()
    await client.query("Hello")
    async for msg in client.receive_response():
        ...
finally:
    await client.disconnect()

async with ClaudeSDKClient(options) as client:
    # 第一轮
    await client.query("创建一个 Python 函数计算斐波那契数")
    async for msg in client.receive_response():
        handle(msg)

    # 第二轮（上下文保持）
    await client.query("给这个函数添加缓存装饰器")
    async for msg in client.receive_response():
        handle(msg)

    # 第三轮
    await client.query("为它写单元测试")
    async for msg in client.receive_response():
        handle(msg)

async with ClaudeSDKClient(options) as client:
    await client.query("分析整个代码库并写一份详细报告")

    # 等待一段时间后中断
    await anyio.sleep(5)
    await client.interrupt()

    # 中断后可以发新查询
    await client.query("只分析 src/ 目录")
    async for msg in client.receive_response():
        handle(msg)

await client.set_permission_mode("bypassPermissions")
await client.query("修改所有配置文件")
async for msg in client.receive_response():
    ...
await client.set_permission_mode("default")  # 恢复

await client.set_model("claude-sonnet-4-5")
await client.query("简单问题")
...
await client.set_model("claude-opus-4-5")
await client.query("复杂推理任务")

options = ClaudeAgentOptions(enable_file_checkpointing=True)
async with ClaudeSDKClient(options) as client:
    await client.query("重构 main.py")
    async for msg in client.receive_response():
        if isinstance(msg, UserMessage) and msg.uuid:
            last_user_msg_id = msg.uuid

    # 发现结果不满意，回退
    await client.rewind_files(last_user_msg_id)

# 查询所有 MCP 服务器状态
status = await client.get_mcp_status()

# 重连某个服务器
await client.reconnect_mcp_server("my-server")

# 禁用/启用服务器
await client.toggle_mcp_server("my-server", enabled=False)