reqwest-eventsource

为reqwest提供简单的包装以提供Event Source实现。您可以了解更多关于服务器发送事件（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提供简单的包装以提供Event Source实现。您可以了解更多关于服务器发送事件（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();
        }
    }
}