7 releases
0.2.3 | Feb 17, 2022 |
---|---|
0.2.2 | Feb 11, 2022 |
0.2.1 | Jan 31, 2022 |
0.1.2 | Oct 21, 2021 |
0.1.1 | Jun 28, 2020 |
#161 in Parser implementations
76,252 downloads per month
Used in 191 crates
(26 directly)
31KB
770 lines
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes array like objects. To learn more about Server Sent Events (SSE) take a look at the MDN docs
Example
let mut stream = reqwest::Client::new()
.get("http://localhost:7020/notifications")
.send()
.await?
.bytes_stream()
.eventsource();
while let Some(thing) = stream.next().await {
println!("{:?}", thing);
}
License: MIT OR Apache-2.0
lib.rs
:
A basic building block for building an Eventsource from a Stream of bytes array like objects. To learn more about Server Sent Events (SSE) take a look at the MDN docs
Example
let mut stream = reqwest::Client::new()
.get("http://localhost:7020/notifications")
.send()
.await?
.bytes_stream()
.eventsource();
while let Some(event) = stream.next().await {
match event {
Ok(event) => println!(
"received event[type={}]: {}",
event.event,
event.data
),
Err(e) => eprintln!("error occured: {}", e),
}
}
Dependencies
~1MB
~20K SLoC