Struct SseParser 

pub struct SseParser { /* private fields */ }

Parses SSE events from a reqwest byte stream.

Example

let response = client.post(url).send().await?;
let mut parser = SseParser::new(response);
while let Some(event) = parser.next_event().await? {
    match event {
        StreamEvent::ContentBlockDelta { delta, .. } => { /* handle */ }
        StreamEvent::MessageStop => break,
        _ => {}
    }
}

Implementations

impl SseParser

pub fn new(response: Response) -> Self

Wrap a reqwest response in an SSE parser

pub async fn next_event( &mut self, ) -> Result<Option<StreamEvent>, ClaudeApiError>

Read the next complete SSE event from the stream. Returns None when the stream ends.