pub fn sse_response<S>(stream: S) -> Responsewhere S: Stream<Item = SseEvent> + Send + Unpin + 'static,
Convenience function to create an SSE response from an iterator.
use fastapi_core::sse::{sse_response, SseEvent}; let events = vec![ SseEvent::message("Hello"), SseEvent::message("World"), ]; let response = sse_response(asupersync::stream::iter(events));