Struct Sse 

pub struct Sse { /* private fields */ }

Builder for a buffered Server-Sent Events response.

Call Sse::into_response to obtain a Response with:

• 200 OK
• Content-Type: text/event-stream
• Cache-Control: no-cache
• X-Accel-Buffering: no (disables nginx proxy buffering)

Example

use rust_web_server::sse::Sse;

let response = Sse::new()
    .event("open", "")
    .data(r#"{"msg":"hello"}"#)
    .retry(5000)
    .into_response();

Implementations

impl Sse

pub fn new() -> Sse

Create an empty SSE response builder.

pub fn event(self, event_type: &str, data: &str) -> Sse

Append a named event with data.

event_type becomes the event: field; data becomes the data: field.

pub fn data(self, data: &str) -> Sse

Append a data-only event (no event: type field; clients receive it as "message").

pub fn push(self, event: SseEvent) -> Sse

Append a fully configured SseEvent (id, type, retry, data).

pub fn retry(self, ms: u32) -> Sse

Append a retry: directive that tells the client how many milliseconds to wait before reconnecting after the connection is lost.

pub fn comment(self, text: &str) -> Sse

Append an SSE comment line (starts with :). Used as a keep-alive ping or annotation; browsers ignore comment content.

pub fn stream() -> (SseSender, Response)

A streaming response and the SseSender that feeds it: 32 events buffered, a keep-alive comment after 15 quiet seconds. See SseStream to change either.

pub fn into_response(self) -> Response

Finalise the builder and return a Response with the correct SSE headers and the accumulated event body.