Struct StreamingResponse 

pub struct StreamingResponse<S: Read + Write> {
    pub status: u16,
    pub headers: Vec<(String, String)>,
    /* private fields */
}

A streamed response: status + headers, plus the reader positioned at the body. The caller decides how to drain it — [into_body] to buffer (application/json) or [sse] to pump it as an SSE event stream (text/event-stream). Owns the underlying stream, matching the MCP client’s per-request connection model.

Fields

status: u16

headers: Vec<(String, String)>

Implementations

impl<S: Read + Write> StreamingResponse<S>

pub fn header(&self, name: &str) -> Option<&str>

pub fn is_success(&self) -> bool

pub fn content_type(&self) -> Option<&str>

The lowercased Content-Type (media type only, params stripped).

pub fn is_event_stream(&self) -> bool

true when the body is text/event-stream (Streamable HTTP SSE).

pub fn into_body(self) -> Result<Vec<u8>>

Buffer the whole body (capped), honoring Content-Length/chunked/close.

pub fn sse(self) -> SseReader<BufReader<S>>

Consume into an SseReader to pump text/event-stream events.

pub fn into_reader(self) -> BufReader<S>

Consume into the raw body reader — for a response that turned out NOT to be an event stream (e.g. a peer that answered application/json).