Struct EventParser 

pub struct EventParser { /* private fields */ }

Incremental SSE parser for Anthropic’s messages stream.

Stateful: feed bytes as they arrive, drain ready events with next_event. Safe to call feed after every network read of any size, including mid-event.

Implementations

impl EventParser

pub fn new() -> Self

Construct an empty parser.

pub fn feed(&mut self, bytes: &[u8]) -> usize

Append bytes to the parser’s buffer and process any complete events.

Non-UTF-8 bytes are dropped (Anthropic’s SSE is always UTF-8 in practice). Returns the number of new events parsed and queued.

pub fn next_event(&mut self) -> Result<Option<Event>, ParseError>

Pull the next ready event, or Ok(None) if the buffer is empty.

pub fn drain(&mut self) -> Vec<Event>

Drain all currently ready events.

pub fn parse_all(text: &str) -> Vec<Event>

Convenience: parse a complete SSE response body all at once.

Trait Implementations

impl Default for EventParser

fn default() -> Self

Returns the “default value” for a type.