Struct SseReader 

pub struct SseReader { /* private fields */ }

Reads server-sent events from a response until it ends or cancel fires.

Implementations

impl SseReader

pub fn new(response: Response) -> SseReader

Reads response as an event stream, as the provider SDKs do: a cancelled read fails with ABORTED_DURING_STREAM.

pub fn fetch(response: Response) -> SseReader

Reads with plain fetch, as pi’s Anthropic client does: a cancelled read fails with ABORTED_READ.

pub async fn next( &mut self, cancel: &CancellationToken, ) -> Result<Option<Event>, String>

The next event, Ok(None) at the end, or an error message.