#http #sse #events #server-sent

mousse

A set of encoder and decoder for server sent events

2 releases

0.1.1 Sep 18, 2021
0.1.0 Sep 18, 2021

#363 in HTTP server

Download history 1625/week @ 2023-06-02 1620/week @ 2023-06-09 1418/week @ 2023-06-16 1518/week @ 2023-06-23 1376/week @ 2023-06-30 1810/week @ 2023-07-07 2040/week @ 2023-07-14 1810/week @ 2023-07-21 2163/week @ 2023-07-28 1876/week @ 2023-08-04 1767/week @ 2023-08-11 1595/week @ 2023-08-18 2175/week @ 2023-08-25 1249/week @ 2023-09-01 2199/week @ 2023-09-08 1936/week @ 2023-09-15

8,132 downloads per month

MIT license

21KB
364 lines

Mousse

An SSE encoder/decoder

Usage

Decode

use futures::stream::StreamExt;
use mousse::Parser;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let url = match std::env::args().nth(1) {
        Some(url) => url,
        None => {
            eprintln!("expected uri argument\ncargo run -- <uri>");
            std::process::exit(1);
        }
    };
    let mut stream = reqwest::get(&url)
        .await?
        .bytes_stream();
    while let Some(chunk) = stream.next().await {
        let chunk = chunk?;
        let string = String::from_utf8_lossy(&chunk);
        let mut parser = Parser::new(&string);
        println!("{:?}", parser.next_event());
    }
    Ok(())
}

Output

If you connect this to an sse server, you might see something like this.

cargo run --example reqwest -- http://localhost:8080/sse
Some(ServerSentEvent { comment: None, event: None, id: None, data: Some("next tick in 5"), retry: None })
Some(ServerSentEvent { comment: Some(""), event: None, id: None, data: None, retry: None })
Some(ServerSentEvent { comment: None, event: None, id: None, data: Some("next tick in 4"), retry: None })
Some(ServerSentEvent { comment: Some(""), event: None, id: None, data: None, retry: None })
Some(ServerSentEvent { comment: None, event: None, id: None, data: Some("next tick in 2"), retry: None })
Some(ServerSentEvent { comment: None, event: None, id: None, data: Some("next tick in 1"), retry: None })

Encode

use mousse::ServerSentEvent;

fn main() {
    for i in 0..10 {
        println!(
            "{}",
            ServerSentEvent::builder()
                .data(&format!("{}: Hi I am a data field", i))
                .id(&i.to_string())
                .build()
        )
    }
}

Output

cargo run --example encode
id:0
data:0: Hi I am a data field


id:1
data:1: Hi I am a data field


id:2
data:2: Hi I am a data field


id:3
data:3: Hi I am a data field


id:4
data:4: Hi I am a data field


id:5
data:5: Hi I am a data field


id:6
data:6: Hi I am a data field


id:7
data:7: Hi I am a data field


id:8
data:8: Hi I am a data field


id:9
data:9: Hi I am a data field


Dependencies

~78KB