Module streaming 

Module: Streaming

Responsibility

Emits agent reasoning events (thought, action, observation, result, error) as Server-Sent Events (SSE) over a tokio::sync::broadcast channel so that multiple HTTP clients can subscribe to a single agent run in real time.

Design

• AgentEvent — the typed event enum; each variant serialises to JSON and is wrapped in the SSE data: …\n\n envelope.
• StreamBroadcaster — thin wrapper around a broadcast::Sender<String>. Call StreamBroadcaster::send to publish an event; call StreamBroadcaster::subscribe to obtain a broadcast::Receiver<String> from which a subscriber reads raw SSE lines.
• AgentEventStream — convenience helper that owns a StreamBroadcaster and exposes typed emit_* methods.

Guarantees

• Non-panicking: all operations return Result
• No unwrap / expect / panic in production paths
• Thread-safe: StreamBroadcaster and AgentEventStream are Clone, Send, and Sync

NOT Responsible For

• HTTP transport (callers wire the Receiver output into their own HTTP layer — axum, actix-web, hyper, etc.)
• Persistence of streamed events

Structs

AgentEventStream

High-level typed event stream for a single agent run.

StreamBroadcaster

A broadcast publisher for raw SSE strings.

Enums

AgentEvent

A single event emitted by a running agent.