Skip to main content

Module sse

Module sse 

Source
Expand description

High-performance Server-Sent Events engine.

SseStream adapts any futures::Stream of SseEvents into a compliant text/event-stream response. The conversion to the transport layer happens once, lazily, inside IntoResponse — handler code only ever touches arcly-owned types (SseStream, SseEvent).

Back-pressure and flushing are delegated to the underlying async runtime: the stream is polled only as fast as the client drains the socket, so a slow consumer never buffers unboundedly inside the framework.

Structs§

SseEvent
A single Server-Sent Event. Builder-style; all fields optional except data.
SseStream
A streaming text/event-stream response body.