Crate eventsource_client

Client for the Server-Sent Events protocol (aka EventSource).

use futures::{TryStreamExt};
use eventsource_client::{Client, SSE};
let mut client = eventsource_client::ClientBuilder::for_url("https://example.com/stream")?
    .header("Authorization", "Basic username:password")?
    .build();

let mut stream = Box::pin(client.stream())
    .map_ok(|event| match event {
        SSE::Comment(comment) => println!("got a comment event: {:?}", comment),
        SSE::Event(evt) => println!("got an event: {}", evt.event_type)
    })
    .map_err(|e| println!("error streaming events: {:?}", e));

Structs

• ClientBuilder
  ClientBuilder provides a series of builder methods to easily construct a Client.
• Event
• ReconnectOptions
  Configuration for a Client’s reconnect behaviour.
• ReconnectOptionsBuilder
  Builder for ReconnectOptions.
• ReconnectingRequest

Enums

• Error
  Error type returned from this library’s functions.
• SSE

Constants

• DEFAULT_REDIRECT_LIMIT
  Maximum amount of redirects that the client will follow before giving up, if not overridden via ClientBuilder::redirect_limit.

Traits

• Client
  Client is the Server-Sent-Events interface. This trait is sealed and cannot be implemented for types outside this crate.

Type Aliases

• BoxStream
  Represents a Pin’d Send + Sync stream, returned by Client’s stream method.
• Result