Crate async_sse

Async Server Sent Event parser and encoder.

Example

use async_sse::{decode, encode, Event};
use async_std::prelude::*;
use async_std::io::BufReader;
use async_std::task;

#[async_std::main]
async fn main() -> http_types::Result<()> {
    // Create an encoder + sender pair and send a message.
    let (sender, encoder) = encode();
    task::spawn(async move {
        sender.send("cat", "chashu", None).await;
    });

    // Decode messages using a decoder.
    let mut reader = decode(BufReader::new(encoder));
    let event = reader.next().await.unwrap()?;
    // Match and handle the event

    Ok(())
}

References

• SSE Spec
• EventSource web platform tests

Structs

Decoder	An SSE protocol decoder.
Encoder	An SSE protocol encoder.
Message	An SSE event with a data payload.
Sender	The sending side of the encoder.

Enums

Event

The kind of SSE event sent.

Functions

decode	Decode a new incoming SSE connection.
encode	Create a new SSE encoder.
upgrade	Upgrade an HTTP connection into an SSE session.