Stream

go run ./agent_with_stream "What's the weather in Tokyo?"
go run ./agent_with_stream "What is 15 + 27?"

a, err := agent.NewAgent(
    agent.WithLLMClient(llmClient),
    agent.WithToolRegistry(reg),
    agent.WithToolApprovalPolicy(agent.AutoToolApprovalPolicy()),
)

// runID is available synchronously — save it for reconnect before consuming events.
agentStream, err := a.Stream(ctx, prompt, nil)
if err != nil {
    log.Fatal(err)
}
runID := agentStream.ID()
_ = runID // persist alongside your session key when crash-durability matters
eventCh, err := agentStream.Events(ctx)
if err != nil {
    log.Fatal(err)
}
for ev := range eventCh {
    if ev == nil {
        continue
    }
    switch ev.Type() {
    case agent.AgentEventTypeTextMessageContent:
        if t, ok := ev.(*agent.AgentTextMessageContentEvent); ok {
            fmt.Print(t.Delta)
        }
    case agent.AgentEventTypeRunFinished:
        // result and LLMUsage available on AgentRunFinishedEvent.Result
    case agent.AgentEventTypeRunError:
        if t, ok := ev.(*agent.AgentRunErrorEvent); ok {
            log.Println("error:", t.Message)
        }
    }
}

The current weather in Tokyo is 18°C, partly cloudy with light winds from the northeast.