tower_async_http::limit

Struct RequestBodyLimit

Source 
pub struct RequestBodyLimit<S> { /* private fields */ }
Available on crate feature limit only.
Expand description

Middleware that intercepts requests with body lengths greater than the configured limit and converts them into 413 Payload Too Large responses.

See the module docs for an example.

Implementations§

Source§

impl<S> RequestBodyLimit<S>

Source

pub fn new(inner: S, limit: usize) -> Self

Create a new RequestBodyLimit with the given body length limit.

Source

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

Source

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

Source

pub fn layer(limit: usize) -> RequestBodyLimitLayer

Returns a new Layer that wraps services with a RequestBodyLimit middleware.

Trait Implementations§

Source§

impl<S: Clone> Clone for RequestBodyLimit<S>

Source§

fn clone(&self) -> RequestBodyLimit<S>

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<S: Debug> Debug for RequestBodyLimit<S>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<ReqBody, ResBody, S> Service<Request<ReqBody>> for RequestBodyLimit<S>
where ResBody: Body, S: Service<Request<Limited<ReqBody>>, Response = Response<ResBody>>,

Source§

type Response = Response<ResponseBody<ResBody>>

Responses given by the service.
Source§

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

Errors produced by the service.
Source§

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

Process the request and return the response asynchronously.
Source§

impl<S: Copy> Copy for RequestBodyLimit<S>

Auto Trait Implementations§

§

impl<S> Freeze for RequestBodyLimit<S>
where S: Freeze,

§

impl<S> RefUnwindSafe for RequestBodyLimit<S>
where S: RefUnwindSafe,

§

impl<S> Send for RequestBodyLimit<S>
where S: Send,

§

impl<S> Sync for RequestBodyLimit<S>
where S: Sync,

§

impl<S> Unpin for RequestBodyLimit<S>
where S: Unpin,

§

impl<S> UnwindSafe for RequestBodyLimit<S>
where S: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Available on crate feature follow-redirect only.
Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Available on crate feature follow-redirect only.
Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, Request> ServiceExt<Request> for T
where T: Service<Request> + ?Sized,

Source§

fn oneshot( self, req: Request, ) -> impl Future<Output = Result<Self::Response, Self::Error>>
where Self: Sized,

Consume this Service, calling it with the provided request once and only once.
Source§

fn and_then<F>(self, f: F) -> AndThen<Self, F>
where Self: Sized, F: Clone,

Executes a new future after this service’s future resolves. Read more
Source§

fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
where Self: Sized, F: Fn(Self::Response) -> Response,

Maps this service’s response value to a different value. Read more
Source§

fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
where Self: Sized, F: Fn(Self::Error) -> Error,

Maps this service’s error value to a different value. Read more
Source§

fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
where Self: Sized, Error: From<Self::Error>, F: Fn(Result<Self::Response, Self::Error>) -> Result<Response, Error>,

Maps this service’s result type (Result<Self::Response, Self::Error>) to a different value, regardless of whether the future succeeds or fails. Read more
Source§

fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
where Self: Sized, F: Fn(NewRequest) -> Request,

Composes a function in front of the service. Read more
Source§

fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
where Self: Sized, Error: From<Self::Error>, F: Fn(Result<Self::Response, Self::Error>) -> Fut, Fut: Future<Output = Result<Response, Error>>,

Composes an asynchronous function after this service. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more