httpp/sse

Types

pub type SSEEvent {
  Event(event_type: Option(String), data: String)
  Closed
}

Event(event_type: Option(String), data: String)

</>

pub type SSEManagerMessage {
  Shutdown
}

</>

pub fn event_source(
  req: Request(BytesBuilder),
  subject: Subject(SSEEvent),
) -> Result(Subject(SSEManagerMessage), StartError)

Send a request to a server-sent events endpoint, and receive events back on a subject you provide