Struct ResumableStream 

pub struct ResumableStream<'client> { /* private fields */ }

A read that reconnects itself, so a dropped stream costs a round trip rather than the session.

Implementations

impl ResumableStream<'_>

pub async fn next_event(&mut self) -> Result<Option<SseEvent>, HttpClientError>

The next event, across as many reconnects as the budget allows.

Errors

HttpClientError::ResumeExhausted once the reconnect budget is spent, carrying how far the read got and why the last attempt ended. A non-transient failure — a malformed frame, a media type this client cannot read, an unparseable session id — is returned as itself, because reconnecting would produce the same one.

pub const fn delivered(&self) -> u64

How many events this read has delivered, across every connection.

pub const fn cursor(&self) -> Option<EventId>

The id a reconnect would ask for.

pub const fn reconnects(&self) -> u32

How many reconnects have been used.

Trait Implementations

impl<'client> Debug for ResumableStream<'client>

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

Formats the value using the given formatter.