eventsource-stream

从字节流数组对象构建 Eventsource 的基本构建块。要了解更多关于服务器端事件 (SSE) 的信息，请查看 MDN 文档

示例

let mut stream = reqwest::Client::new()
    .get("https://127.0.0.1:7020/notifications")
    .send()
    .await?
    .bytes_stream()
    .eventsource();

while let Some(thing) = stream.next().await {
   println!("{:?}", thing);
}

许可证：MIT OR Apache-2.0

lib.rs:

从字节流数组对象构建 Eventsource 的基本构建块。要了解更多关于服务器端事件 (SSE) 的信息，请查看 MDN 文档

示例

let mut stream = reqwest::Client::new()
    .get("https://127.0.0.1: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),
    }
}