Enum CompressionBody 

pub enum CompressionBody<B> {
    Compressed {
        inner: B,
        state: CompressedBody,
    },
    Passthrough {
        inner: B,
    },
}

A response body that may be compressed.

This type wraps an inner body and either compresses it using the specified codec or passes it through unchanged.

Variants

Compressed

Compressed body with encoder.

Fields

inner: B

state: CompressedBody

Passthrough

Passthrough body without compression.

Fields

inner: B

Implementations

impl<B> CompressionBody<B>

pub fn compressed(inner: B, codec: Codec, always_flush: bool) -> Self

Creates a compressed body with the given codec.

pub fn passthrough(inner: B) -> Self

Creates a passthrough body without compression.

Trait Implementations

impl<B> Body for CompressionBody<B>

where B: Body, B::Data: Buf, B::Error: Into<Box<dyn Error + Send + Sync>>,

type Data = Bytes

Values yielded by the Body.

type Error = Error

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<'__pin, B> Unpin for CompressionBody<B>

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