Struct EventStream 

pub struct EventStream { /* private fields */ }

An async stream of StreamResponse events from an SSE endpoint.

Created by crate::A2aClient::stream_message or crate::A2aClient::subscribe_to_task. Call EventStream::next in a loop to consume events.

When dropped, the background body-reader task is aborted to prevent resource leaks.

Implementations

impl EventStream

pub const fn status_code(&self) -> u16

Returns the HTTP status code from the response that established this stream.

The transport layer validates the HTTP status during stream establishment and returns an error for non-2xx responses, so this is typically 200.

pub async fn next(&mut self) -> Option<Result<StreamResponse, ClientError>>

Returns the next event from the stream.

Returns None when the stream ends normally (either the HTTP body closed or a final: true event was received).

Returns Some(Err(...)) on transport or protocol errors.

Trait Implementations

impl Debug for EventStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Drop for EventStream

fn drop(&mut self)

Executes the destructor for this type.