typedrest-reactive/net.typedrest.http/SseReader

SseReader

class SseReader(source: BufferedSource)

Reads ServerSentEvents from an HTTP response body in the text/event-stream format.

Parameters

source

The response body to read from.

Constructors

constructor(source: BufferedSource)

Properties

var lastEventId: String?

The id of the most recent event that carried an id: field.

reconnectionInterval

var reconnectionInterval: Duration?

The reconnection interval most recently requested by the server via a retry: field if any.

Functions

fun events(): Sequence<ServerSentEvent>

Reads events until the stream ends.