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.