Struct SseCodec 

pub struct SseCodec;

SSE codec for parsing streaming responses

Implementations

impl SseCodec

pub fn new() -> Self

Create a new SSE codec

pub fn parse_stream<S>( &self, byte_stream: S, ) -> impl Stream<Item = Result<SseEvent, A2AError>>

where S: Stream<Item = Result<Bytes, Error>> + Send + 'static,

Parse an SSE byte stream into a stream of events

This method takes a byte stream (typically from reqwest) and parses it into individual SSE events containing JSON-RPC responses.

Trait Implementations

impl Clone for SseCodec

fn clone(&self) -> SseCodec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SseCodec

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

Formats the value using the given formatter.

impl Default for SseCodec

fn default() -> Self

Returns the “default value” for a type.