[−][src]Crate 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
For more examples with delaying and error handling, take a look at the examples/
let client = Client::new(); let mut stream = client .get("http://localhost:7020/notifications") .eventsource()?; while let Some(event) = stream.next().await { match event { Ok(event) => println!( "received: {:?}: {}", event.event, String::from_utf8_lossy(&event.data) ), Err(e) => eprintln!("error occured: {}", e), } }
Structs
CannotCloneRequestError | Error raised when a |
Event | An Event |
EventsourceRequestBuilder | Provides the |
Enums
Error | Wrapper for |
ParseError | Error thrown while parsing an event line |
Traits
RequestBuilderExt | Provides an easy interface to build an |