Struct EventSource 

pub struct EventSource { /* private fields */ }

Reconnecting SSE event source backed by a backend-neutral connector.

Implementations

impl EventSource

pub fn new<C>(connector: C) -> Self

where C: Connector,

Creates a reconnecting event source from a backend-neutral connector.

pub fn with_retry_policy<P>(self, retry_policy: P) -> Self

where P: RetryPolicy,

Replaces the reconnect timing policy.

Built-in policies include ConstantBackoff, crate::replayable::ExponentialBackoff, and crate::replayable::NeverRetry. Custom policies may implement crate::replayable::RetryPolicy directly.

pub fn last_event_id(&self) -> Option<&str>

Returns the current effective Last-Event-ID, if one is stored.

This value is updated from the SSE stream and reused on future reconnect attempts through the underlying connector.

pub fn set_last_event_id(&mut self, last_event_id: impl Into<String>)

Replaces the stored Last-Event-ID.

This affects the next reconnect attempt and overrides any previously remembered value until the stream updates it again.

pub fn clear_last_event_id(&mut self)

Clears the stored Last-Event-ID.

Future reconnect attempts will omit the header until the stream observes a new event id.

Trait Implementations

impl Clone for EventSource

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventSource

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

Formats the value using the given formatter.

impl Stream for EventSource

type Item = Result<Event, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.