Enum StreamingBody 

pub enum StreamingBody<B> {
    Buffered {
        data: Option<Bytes>,
    },
    Streaming {
        inner: B,
    },
}

A body type that can represent either buffered data from cache or streaming body from upstream.

This enum allows the HTTP cache middleware to efficiently handle:

• Cached responses (buffered data)
• Cache misses (streaming from upstream)

Variants

• Buffered: Contains cached response data that can be sent immediately
• Streaming: Wraps an upstream body for streaming responses

Variants

Buffered

Fields

data: Option<Bytes>

Streaming

Fields

inner: B

Implementations

impl<B> StreamingBody<B>

pub fn buffered(data: Bytes) -> Self

Create a new buffered body from bytes.

The bytes are consumed on the first poll and sent as a single frame.

pub fn streaming(body: B) -> Self

Create a new streaming body from an upstream body.

The upstream body is passed through without additional buffering.

Trait Implementations

impl<B> Body for StreamingBody<B>

where B: Body + Unpin, B::Error: Into<StreamingError>, B::Data: Into<Bytes>,

Available on non-crate feature streaming only.

type Data = Bytes

Values yielded by the Body.

type Error = StreamingError

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

impl<B: Debug> Debug for StreamingBody<B>

Available on non-crate feature streaming only.

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

Formats the value using the given formatter.

impl<B> From<Bytes> for StreamingBody<B>

fn from(bytes: Bytes) -> Self

Converts to this type from the input type.

impl<'__pin, B> Unpin for StreamingBody<B>

where PinnedFieldsOf<__Origin<'__pin, B>>: Unpin,