Sova

Appearance

sse ​

Server-Sent Events helpers for Sova (channels, Last-Event-ID, keep-alive)

Cratesova-sse 0.1.1
Plugin idsse
CategoryRealtime

Install ​

bash
cargo add sova --features sse-feed

Features ​

FeatureWhat you get
sse-feedSSE channel helpers (SseChannel, sse_response).

Overview ​

When: Server-Sent Events streams to browsers.

Does:

  • SseChannel + SseEvent (id / event / data)
  • sse_response with keep-alive + Last-Event-ID replay
  • No separate Sse plugin — app.state(channel)

Example ​

rust
let channel = SseChannel::new(64);
app.state(channel.clone());
app.get("/events", |req: Request| async move {
    let ch = req.state::<SseChannel>();
    sse_response(&req, &ch, Duration::from_secs(15))
});

Quick start ​

rust
use sova::{sse_response, App, Request, Result, SseChannel, SseEvent};
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<()> {
    let channel = SseChannel::new(64);
    let pub_ch = channel.clone();
    tokio::spawn(async move {
        let mut n = 0u64;
        loop {
            tokio::time::sleep(Duration::from_secs(1)).await;
            n += 1;
            pub_ch.publish(SseEvent::data(format!("tick {n}")).id(n.to_string()));
        }
    });

    let mut app = App::new();
    app.state(channel);
    app.get("/events", |req: Request| async move {
        let ch = req.state::<SseChannel>();
        sse_response(&req, &ch, Duration::from_secs(15))
    });
    app.run().await
}

There is no Sse plugin — use SseChannel + app.state (see examples/realtime/sse_feed).

bash
cargo run -p sse_feed

Examples ​

ws