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
letmut stream = reqwest::Client::new().get("http://localhost:7020/notifications").send().await?
.bytes_stream().eventsource();whileletSome(thing) = stream.next().await{println!("{:?}", thing);}License: MIT OR Apache-2.0