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.