Enum ResponseBody 

pub enum ResponseBody {
    Complete(Vec<u8>),
    Stream(Pin<Box<dyn Stream<Item = Result<Bytes>> + Send>>),
    Subscription(Subscription, ContentType),
}

Response body — complete or streaming.

Variants

Complete(Vec<u8>)

Complete response body

Stream(Pin<Box<dyn Stream<Item = Result<Bytes>> + Send>>)

Streaming response body (for large datasets)

Subscription(Subscription, ContentType)

Real-time subscription tagged with the negotiated streaming format (Sse, GrpcWeb, …). The HTTP layer looks the format up in its subscription-encoder registry to produce the wire response — the format travels as a type, not a re-parsed Content-Type header.

Implementations

impl ResponseBody

pub const fn complete(data: Vec<u8>) -> Self

Create a complete response body.

pub fn stream<S>(stream: S) -> Self

where S: Stream<Item = Result<Bytes>> + Send + 'static,

Create a streaming response body.

pub const fn subscription(sub: Subscription, format: ContentType) -> Self

Create a subscription response body tagged with the negotiated streaming format the HTTP layer should encode it as.

pub fn into_bytes(self) -> Option<Vec<u8>>

Extract bytes from a Complete response body.

pub const fn as_bytes(&self) -> Option<&[u8]>

Get reference to bytes from a Complete response body.

Trait Implementations

impl Debug for ResponseBody

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.