reqwest-eventsource

提供对reqwest的简单封装，以提供事件源实现。您可以了解更多关于服务器发送事件（SSE）的信息，请参阅MDN文档。此crate使用eventsource_stream封装底层的字节流，并重试失败的请求。

示例

let mut es = EventSource::get("https://127.0.0.1:8000/events");
while let Some(event) = es.next().await {
    match event {
        Ok(Event::Open) => println!("Connection Open!"),
        Ok(Event::Message(message)) => println!("Message: {:#?}", message),
        Err(err) => {
            println!("Error: {}", err);
            es.close();
        }
    }
}

许可：MIT OR Apache-2.0

lib.rs:

提供对reqwest的简单封装，以提供事件源实现。您可以了解更多关于服务器发送事件（SSE）的信息，请参阅MDN文档。此crate使用eventsource_stream封装底层的字节流，并重试失败的请求。

示例

let mut es = EventSource::get("https://127.0.0.1:8000/events");
while let Some(event) = es.next().await {
    match event {
        Ok(Event::Open) => println!("Connection Open!"),
        Ok(Event::Message(message)) => println!("Message: {:#?}", message),
        Err(err) => {
            println!("Error: {}", err);
            es.close();
        }
    }
}