Struct SseClient 

pub struct SseClient { /* private fields */ }

SSE client for consuming AG-UI event streams.

The client connects to an SSE endpoint and provides a stream of parsed AG-UI events.

Implementations

impl SseClient

pub async fn connect(url: &str) -> Result<Self>

Connects to an SSE endpoint with default configuration.

Arguments

• url - The SSE endpoint URL

Example

let client = SseClient::connect("http://localhost:3000/events").await?;

pub async fn connect_with_config(url: &str, config: SseConfig) -> Result<Self>

Connects to an SSE endpoint with custom configuration.

Arguments

• url - The SSE endpoint URL
• config - Connection configuration

Example

let config = SseConfig::new()
    .connect_timeout(Duration::from_secs(60))
    .bearer_token("my-token");
let client = SseClient::connect_with_config("http://localhost:3000/events", config).await?;

pub fn into_stream(self) -> SseEventStream

Converts this client into an event stream.

The stream yields parsed AG-UI events as they arrive.