Struct StreamCompression 

pub struct StreamCompression<S, P = DefaultStreamPredicate> { /* private fields */ }

Available on crate feature compression only.

Compress response bodies of the underlying service.

This uses the Accept-Encoding header to pick an appropriate encoding and adds the Content-Encoding header to responses.

See the module docs for more details.

Implementations

impl<S> StreamCompression<S, DefaultStreamPredicate>

pub fn new(service: S) -> Self

Creates a new StreamCompression wrapping the service.

impl<S, P> StreamCompression<S, P>

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

pub fn with_gzip(self, enable: bool) -> Self

Sets whether to enable the gzip encoding.

pub fn set_gzip(&mut self, enable: bool) -> &mut Self

Sets whether to enable the gzip encoding.

pub fn with_deflate(self, enable: bool) -> Self

Sets whether to enable the Deflate encoding.

pub fn set_deflate(&mut self, enable: bool) -> &mut Self

Sets whether to enable the Deflate encoding.

pub fn with_br(self, enable: bool) -> Self

Sets whether to enable the Brotli encoding.

pub fn set_br(&mut self, enable: bool) -> &mut Self

Sets whether to enable the Brotli encoding.

pub fn with_zstd(self, enable: bool) -> Self

Sets whether to enable the Zstd encoding.

pub fn set_zstd(&mut self, enable: bool) -> &mut Self

Sets whether to enable the Zstd encoding.

pub fn with_quality(self, quality: CompressionLevel) -> Self

Sets the StreamCompression quality.

pub fn set_quality(&mut self, quality: CompressionLevel) -> &mut Self

Sets the StreamCompression quality.

pub fn with_enforce_not_acceptable(self, enable: bool) -> Self

Sets whether to respond with 406 Not Acceptable when the client’s Accept-Encoding header rejects every available representation (e.g. *;q=0 or a lone identity;q=0), as recommended by RFC 9110 §12.5.3.

Enabled by default. Disable to opt out and instead fall back to sending an uncompressed (identity) response regardless of the client’s stated preference.

pub fn set_enforce_not_acceptable(&mut self, enable: bool) -> &mut Self

Sets whether to respond with 406 Not Acceptable when the client’s Accept-Encoding header rejects every available representation (e.g. *;q=0 or a lone identity;q=0), as recommended by RFC 9110 §12.5.3.

Enabled by default. Disable to opt out and instead fall back to sending an uncompressed (identity) response regardless of the client’s stated preference.

pub fn with_compress_predicate<C>(self, predicate: C) -> StreamCompression<S, C>

where C: Predicate,

Replace the current StreamCompression predicate.

Predicates are used to determine whether a response should be compressed or not.

The default predicate is DefaultPredicate. See its documentation for more details on which responses it won’t compress.

Trait Implementations

impl<S: Clone, P: Clone> Clone for StreamCompression<S, P>

fn clone(&self) -> StreamCompression<S, P>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug, P: Debug> Debug for StreamCompression<S, P>

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

Formats the value using the given formatter.

impl<ReqBody, ResBody, S, P> Service<Request<ReqBody>> for StreamCompression<S, P>

where S: Service<Request<ReqBody>, Output = Response<ResBody>>, ResBody: StreamingBody<Data: Send + 'static, Error: Send + 'static> + Send + 'static, P: Predicate + Send + Sync + 'static, ReqBody: Send + 'static,

type Output = Response<StreamCompressionBody<ResBody>>

The type of the output returned by the service.

type Error = <S as Service<Request<ReqBody>>>::Error

The type of error returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<Self::Output, Self::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.