Struct warp::filters::sse::KeepAlive

pub struct KeepAlive {
    comment_text: Cow<'static, str>,
    max_interval: Duration,
}

Configure the interval between keep-alive messages, the content of each message, and the associated stream.

Fields

comment_text: Cow<'static, str>

max_interval: Duration

Implementations

impl KeepAlive

pub fn interval(self, time: Duration) -> Self

Customize the interval between keep-alive messages.

Default is 15 seconds.

pub fn text(self, text: impl Into<Cow<'static, str>>) -> Self

Customize the text of the keep-alive message.

Default is an empty comment.

pub fn stream<S>( self, event_stream: S, ) -> impl TryStream<Ok = Event, Error = impl StdError + Send + Sync + 'static> + Send + 'static

where S: TryStream<Ok = Event> + Send + 'static, S::Error: StdError + Send + Sync + 'static,

Wrap an event stream with keep-alive functionality.

See keep_alive for more.

Trait Implementations

impl Debug for KeepAlive

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

Formats the value using the given formatter.