Streaming

import asyncio
from afk.agents import Agent
from afk.core import Runner

agent = Agent(name="explainer", model="gpt-5.5", instructions="Explain clearly.")

async def main():
    runner = Runner()
    handle = await runner.run_stream(agent, user_message="Explain DNS resolution")

    async for event in handle:
        match event.type:
            case "text_delta":
                print(event.text_delta, end="", flush=True)
            case "tool_completed":
                if not event.tool_success:
                    print(f"\n[TOOL ERROR] {event.tool_name}: {event.tool_error}")
            case "completed":
                print(f"\n[DONE] {event.result.state}")

asyncio.run(main())

stream = await runner.run_stream(agent, user_message="Long analysis...")
async for event in stream:
    ...
result = stream.result

# Lifecycle control variant
handle = await runner.run_handle(agent, user_message="Long analysis...")
await handle.pause()
await handle.resume()
await handle.interrupt()
result = await handle.await_result()

stream = await runner.run_stream(agent, user_message="Implement feature, run build, and write docs")
async for event in stream:
    if event.type == "tool_deferred" and event.tool_name == "build_project":
        print(f"[build queued] ticket={event.tool_ticket_id}")
    elif event.type == "tool_background_resolved" and event.tool_name == "build_project":
        print(f"[build done] output={event.tool_output}")
    elif event.type == "text_delta":
        print(event.text_delta, end="")