Struct StreamParser 

pub struct StreamParser {
    pub model: Option<String>,
    pub request_id: Option<String>,
    /* private fields */
}

Accumulates streaming data and produces StreamEvent values.

Maintains partial state for each content block index as deltas arrive, then emits a ContentBlockComplete when the block is finalized.

Fields

model: Option<String>

Model that generated this response.

request_id: Option<String>

API request ID.

Implementations

impl StreamParser

pub fn new() -> Self

pub fn process(&mut self, raw: RawSseEvent) -> Vec<StreamEvent>

Process a raw SSE event and return any resulting stream events.