Struct WsClient 

pub struct WsClient { /* private fields */ }

WebSocket client for consuming AG-UI event streams.

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

Implementations

impl WsClient

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

Connects to a WebSocket endpoint with default configuration.

Arguments

• url - The WebSocket endpoint URL (ws:// or wss://)

Example

let client = WsClient::connect("ws://localhost:3000/ws").await?;

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

Connects to a WebSocket endpoint with custom configuration.

Arguments

• url - The WebSocket endpoint URL (ws:// or wss://)
• config - Connection configuration

Example

let config = WsConfig::new()
    .bearer_token("my-token");
let client = WsClient::connect_with_config("ws://localhost:3000/ws", config).await?;

pub fn into_stream(self) -> WsEventStream

Converts this client into an event stream.

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

pub async fn close(self) -> Result<()>

Closes the WebSocket connection gracefully.