Struct SseStream 

pub struct SseStream { /* private fields */ }

Options for a streaming SSE response; Sse::stream uses the defaults.

use std::time::Duration;
use rust_web_server::sse::SseStream;

let (events, response) = SseStream::new().buffer(256).keep_alive(Duration::from_secs(5)).start();

Implementations

impl SseStream

pub fn new() -> SseStream

32 events buffered, keep-alive every 15 seconds.

pub fn buffer(self, events: usize) -> SseStream

How many events may wait for a slow client before SseSender::send blocks (and SseSender::try_send drops).

pub fn keep_alive(self, interval: Duration) -> SseStream

After this long with nothing sent, a : keep-alive comment goes out: proxies keep the connection, and a client that left is noticed.

pub fn start(self) -> (SseSender, Response)

The sender and the response to return from the handler.

Trait Implementations

impl Default for SseStream

fn default() -> SseStream

Returns the “default value” for a type.