Struct StreamEvent 

pub struct StreamEvent {
    pub event_id: Option<u64>,
    pub item: StreamItem,
}

A streamed StreamItem tagged with the server’s SSE event id (when the transport supports it). A resilient client records the most recent event_id and echoes it as Last-Event-ID on reconnect to resume without gaps.

The event_id is part of the a2a-rs resumption enhancement (see subscribe_to_task); spec clients that only read item are unaffected.

Fields

event_id: Option<u64>

The server-assigned per-task event id, parsed from the SSE id: field. None for the initial task snapshot, for transports without event ids, or when talking to a spec-compliant server that does not emit id:.

item: StreamItem

The update payload.

Implementations

impl StreamEvent

pub fn new(event_id: Option<u64>, item: StreamItem) -> Self

Construct a stream event.

pub fn untagged(item: StreamItem) -> Self

A stream event with no id (initial snapshot / id-less transport).

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.