Http4kSseClient

class Http4kSseClient(sseRequest: Request, http: HttpHandler, reconnectionMode: ReconnectionMode = Disconnect, reportError: (Exception) -> Unit = {}) : SseClient

Simple SSE client leveraging standard HttpHandlers. Tracks a single connection only and sends reconnection requests including the last event id.

Note that the representation uses an unbounded blocking queue, so clients are required to consume messages using received().

Constructors

Link copied to clipboard
constructor(sseRequest: Request, http: HttpHandler, reconnectionMode: ReconnectionMode = Disconnect, reportError: (Exception) -> Unit = {})

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun received(): Sequence<SseMessage>
Link copied to clipboard

Use this client nd then close it