pub struct Decompression<S> { /* private fields */ }
Expand description
Decompresses response bodies of the underlying service.
This adds the Accept-Encoding
header to requests and transparently decompresses response
bodies based on the Content-Encoding
header.
See the module docs for more details.
Implementations§
Source§impl<S> Decompression<S>
impl<S> Decompression<S>
Sourcepub fn new(service: S) -> Decompression<S>
pub fn new(service: S) -> Decompression<S>
Creates a new Decompression
wrapping the service
.
Sourcepub fn into_inner(self) -> S
pub fn into_inner(self) -> S
Consumes self
, returning the underlying service.
Sourcepub fn layer() -> DecompressionLayer
pub fn layer() -> DecompressionLayer
Returns a new Layer
that wraps services with a Decompression
middleware.
Sourcepub fn gzip(self, enable: bool) -> Decompression<S>
pub fn gzip(self, enable: bool) -> Decompression<S>
Sets whether to request the gzip encoding.
Sourcepub fn deflate(self, enable: bool) -> Decompression<S>
pub fn deflate(self, enable: bool) -> Decompression<S>
Sets whether to request the Deflate encoding.
Sourcepub fn br(self, enable: bool) -> Decompression<S>
pub fn br(self, enable: bool) -> Decompression<S>
Sets whether to request the Brotli encoding.
Sourcepub fn zstd(self, enable: bool) -> Decompression<S>
pub fn zstd(self, enable: bool) -> Decompression<S>
Sets whether to request the Zstd encoding.
Sourcepub fn no_gzip(self) -> Decompression<S>
pub fn no_gzip(self) -> Decompression<S>
Disables the gzip encoding.
This method is available even if the gzip
crate feature is disabled.
Sourcepub fn no_deflate(self) -> Decompression<S>
pub fn no_deflate(self) -> Decompression<S>
Disables the Deflate encoding.
This method is available even if the deflate
crate feature is disabled.
Sourcepub fn no_br(self) -> Decompression<S>
pub fn no_br(self) -> Decompression<S>
Disables the Brotli encoding.
This method is available even if the br
crate feature is disabled.
Sourcepub fn no_zstd(self) -> Decompression<S>
pub fn no_zstd(self) -> Decompression<S>
Disables the Zstd encoding.
This method is available even if the zstd
crate feature is disabled.
Trait Implementations§
Source§impl<S> Clone for Decompression<S>where
S: Clone,
impl<S> Clone for Decompression<S>where
S: Clone,
Source§fn clone(&self) -> Decompression<S>
fn clone(&self) -> Decompression<S>
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl<S> Debug for Decompression<S>where
S: Debug,
impl<S> Debug for Decompression<S>where
S: Debug,
Source§impl<S, ReqBody, ResBody> Service<Request<ReqBody>> for Decompression<S>
impl<S, ReqBody, ResBody> Service<Request<ReqBody>> for Decompression<S>
Source§type Response = Response<DecompressionBody<ResBody>>
type Response = Response<DecompressionBody<ResBody>>
Source§type Future = ResponseFuture<<S as Service<Request<ReqBody>>>::Future>
type Future = ResponseFuture<<S as Service<Request<ReqBody>>>::Future>
Auto Trait Implementations§
impl<S> Freeze for Decompression<S>where
S: Freeze,
impl<S> RefUnwindSafe for Decompression<S>where
S: RefUnwindSafe,
impl<S> Send for Decompression<S>where
S: Send,
impl<S> Sync for Decompression<S>where
S: Sync,
impl<S> Unpin for Decompression<S>where
S: Unpin,
impl<S> UnwindSafe for Decompression<S>where
S: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<S, R> ServiceExt<R> for Swhere
S: Service<R>,
impl<S, R> ServiceExt<R> for Swhere
S: Service<R>,
Source§fn into_make_service(self) -> IntoMakeService<S>
fn into_make_service(self) -> IntoMakeService<S>
MakeService
, that is a Service
whose
response is another service. Read moreSource§fn into_make_service_with_connect_info<C>(
self,
) -> IntoMakeServiceWithConnectInfo<S, C>
fn into_make_service_with_connect_info<C>( self, ) -> IntoMakeServiceWithConnectInfo<S, C>
MakeService
, that will store C
’s
associated ConnectInfo
in a request extension such that ConnectInfo
can extract it. Read moreSource§fn handle_error<F, T>(self, f: F) -> HandleError<Self, F, T>
fn handle_error<F, T>(self, f: F) -> HandleError<Self, F, T>
HandleError
, that will handle errors
by converting them into responses. Read moreSource§impl<R, T> ServiceExt<R> for Twhere
T: Service<R>,
impl<R, T> ServiceExt<R> for Twhere
T: Service<R>,
Source§fn propagate_header(self, header: HeaderName) -> PropagateHeader<Self>
fn propagate_header(self, header: HeaderName) -> PropagateHeader<Self>
Source§fn add_extension<T>(self, value: T) -> AddExtension<Self, T>
fn add_extension<T>(self, value: T) -> AddExtension<Self, T>
Source§fn map_request_body<F>(self, f: F) -> MapRequestBody<Self, F>
fn map_request_body<F>(self, f: F) -> MapRequestBody<Self, F>
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>
Source§fn compression(self) -> Compression<Self>
fn compression(self) -> Compression<Self>
Source§fn decompression(self) -> Decompression<Self>
fn decompression(self) -> Decompression<Self>
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>
Source§fn follow_redirects(self) -> FollowRedirect<Self>
fn follow_redirects(self) -> FollowRedirect<Self>
Source§fn sensitive_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<SetSensitiveResponseHeaders<Self>>
fn sensitive_headers( self, headers: impl IntoIterator<Item = HeaderName>, ) -> SetSensitiveRequestHeaders<SetSensitiveResponseHeaders<Self>>
Source§fn sensitive_request_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<Self>
fn sensitive_request_headers( self, headers: impl IntoIterator<Item = HeaderName>, ) -> SetSensitiveRequestHeaders<Self>
Source§fn sensitive_response_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveResponseHeaders<Self>
fn sensitive_response_headers( self, headers: impl IntoIterator<Item = HeaderName>, ) -> SetSensitiveResponseHeaders<Self>
Source§fn override_request_header<M>(
self,
header_name: HeaderName,
make: M,
) -> SetRequestHeader<Self, M>
fn override_request_header<M>( self, header_name: HeaderName, make: M, ) -> SetRequestHeader<Self, M>
Source§fn append_request_header<M>(
self,
header_name: HeaderName,
make: M,
) -> SetRequestHeader<Self, M>
fn append_request_header<M>( self, header_name: HeaderName, make: M, ) -> SetRequestHeader<Self, M>
Source§fn insert_request_header_if_not_present<M>(
self,
header_name: HeaderName,
make: M,
) -> SetRequestHeader<Self, M>
fn insert_request_header_if_not_present<M>( self, header_name: HeaderName, make: M, ) -> SetRequestHeader<Self, M>
Source§fn override_response_header<M>(
self,
header_name: HeaderName,
make: M,
) -> SetResponseHeader<Self, M>
fn override_response_header<M>( self, header_name: HeaderName, make: M, ) -> SetResponseHeader<Self, M>
Source§fn append_response_header<M>(
self,
header_name: HeaderName,
make: M,
) -> SetResponseHeader<Self, M>
fn append_response_header<M>( self, header_name: HeaderName, make: M, ) -> SetResponseHeader<Self, M>
Source§fn insert_response_header_if_not_present<M>(
self,
header_name: HeaderName,
make: M,
) -> SetResponseHeader<Self, M>
fn insert_response_header_if_not_present<M>( self, header_name: HeaderName, make: M, ) -> SetResponseHeader<Self, M>
Source§fn set_request_id<M>(
self,
header_name: HeaderName,
make_request_id: M,
) -> SetRequestId<Self, M>where
M: MakeRequestId,
fn set_request_id<M>(
self,
header_name: HeaderName,
make_request_id: M,
) -> SetRequestId<Self, M>where
M: MakeRequestId,
Source§fn set_x_request_id<M>(self, make_request_id: M) -> SetRequestId<Self, M>where
M: MakeRequestId,
fn set_x_request_id<M>(self, make_request_id: M) -> SetRequestId<Self, M>where
M: MakeRequestId,
x-request-id
as the header name. Read moreSource§fn propagate_request_id(
self,
header_name: HeaderName,
) -> PropagateRequestId<Self>
fn propagate_request_id( self, header_name: HeaderName, ) -> PropagateRequestId<Self>
Source§fn propagate_x_request_id(self) -> PropagateRequestId<Self>
fn propagate_x_request_id(self) -> PropagateRequestId<Self>
x-request-id
as the header name. Read moreSource§fn catch_panic(self) -> CatchPanic<Self, DefaultResponseForPanic>
fn catch_panic(self) -> CatchPanic<Self, DefaultResponseForPanic>
500 Internal Server
responses. Read moreSource§fn request_body_limit(self, limit: usize) -> RequestBodyLimit<Self>
fn request_body_limit(self, limit: usize) -> RequestBodyLimit<Self>
413 Payload Too Large
responses. Read moreSource§fn trim_trailing_slash(self) -> NormalizePath<Self>
fn trim_trailing_slash(self) -> NormalizePath<Self>
Source§impl<T, Request> ServiceExt<Request> for T
impl<T, Request> ServiceExt<Request> for T
Source§fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
Source§fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
Source§fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
Service
, calling it with the provided request once it is ready.Source§fn and_then<F>(self, f: F) -> AndThen<Self, F>
fn and_then<F>(self, f: F) -> AndThen<Self, F>
poll_ready
method. Read moreSource§fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
poll_ready
method. Read moreSource§fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
poll_ready
method. Read moreSource§fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
Result<Self::Response, Self::Error>
)
to a different value, regardless of whether the future succeeds or
fails. Read moreSource§fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
Source§fn filter_async<F, NewRequest>(self, filter: F) -> AsyncFilter<Self, F>where
Self: Sized,
F: AsyncPredicate<NewRequest>,
fn filter_async<F, NewRequest>(self, filter: F) -> AsyncFilter<Self, F>where
Self: Sized,
F: AsyncPredicate<NewRequest>,
AsyncFilter
that conditionally accepts or
rejects requests based on an [async predicate]. Read more