Struct SseResponse 

pub struct SseResponse<S> { /* private fields */ }

Builder for creating SSE responses.

Example

use fastapi_core::sse::{SseEvent, SseResponse};
use asupersync::stream;

async fn events() -> Response {
    let events = stream::iter(vec![
        SseEvent::message("Hello"),
        SseEvent::message("World"),
    ]);

    SseResponse::new(events)
        .into_response()
}

Implementations

impl<S> SseResponse<S>

where S: Stream<Item = SseEvent> + Send + Unpin + 'static,

pub fn new(stream: S) -> Self

Create a new SSE response from an event stream.

pub fn with_config(stream: S, config: SseConfig) -> Self

Create an SSE response with custom configuration.

pub fn into_response(self) -> Response

Convert to an HTTP Response.

Sets the appropriate headers for SSE:

• Content-Type: text/event-stream
• Cache-Control: no-cache
• Connection: keep-alive