6 releases (breaking)

0.6.0 Mar 29, 2024
0.5.0 Oct 4, 2023
0.4.0 Feb 21, 2022
0.3.0 Jan 11, 2022
0.1.0 Jun 28, 2020

#20 in HTTP client

Download history 27080/week @ 2025-01-28 26913/week @ 2025-02-04 24448/week @ 2025-02-11 26839/week @ 2025-02-18 31559/week @ 2025-02-25 31590/week @ 2025-03-04 33477/week @ 2025-03-11 34207/week @ 2025-03-18 37080/week @ 2025-03-25 39172/week @ 2025-04-01 39847/week @ 2025-04-08 38639/week @ 2025-04-15 42403/week @ 2025-04-22 39086/week @ 2025-04-29 39581/week @ 2025-05-06 31809/week @ 2025-05-13

159,413 downloads per month
Used in 316 crates (63 directly)

MIT/Apache

21KB
403 lines

Provides a simple wrapper for reqwest to provide an Event Source implementation. You can learn more about Server Sent Events (SSE) take a look at the MDN docs This crate uses eventsource_stream to wrap the underlying Bytes stream, and retries failed requests.

Example

let mut es = EventSource::get("http://localhost: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();
        }
    }
}

reqwest-eventsource

Provides a simple wrapper for reqwest to provide an Event Source implementation. You can learn more about Server Sent Events (SSE) take a look at the MDN docs This crate uses eventsource_stream to wrap the underlying Bytes stream, and retries failed requests.

Example

let mut es = EventSource::get("http://localhost: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();
        }
    }
}

License: MIT OR Apache-2.0

Dependencies

~5–17MB
~214K SLoC