Struct volo_http::BodyIncoming

pub struct BodyIncoming { /* private fields */ }

A stream of Bytes, used when receiving bodies from the network.

Note that Users should not instantiate this struct directly. When working with the hyper client, Incoming is returned to you in responses. Similarly, when operating with the hyper server, it is provided within requests.

Examples

async fn echo(
   req: Request<hyper::body::Incoming>,
) -> Result<Response<BoxBody<Bytes, hyper::Error>>, hyper::Error> {
   //Here, you can process `Incoming`
}

Trait Implementations

impl Body for Incoming

type Data = Bytes

Values yielded by the Body.

type Error = Error

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Incoming>, cx: &mut Context<'_> ) -> Poll<Option<Result<Frame<<Incoming as Body>::Data>, <Incoming as Body>::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 Debug for Incoming

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

Formats the value using the given formatter.

impl<S: Sync> FromRequest<S> for Incoming

type Rejection = Infallible

async fn from_request( _cx: &mut HttpContext, body: Incoming, _state: &S ) -> Result<Self, Self::Rejection>

impl<S, T> Service<HttpContext, Incoming> for ExtensionService<S, T>

where S: Service<HttpContext, Incoming, Response = Response, Error = Infallible> + Send + Sync + 'static, T: Clone + Send + Sync + 'static,

type Response = <S as Service<HttpContext, Incoming>>::Response

Responses given by the service.

type Error = <S as Service<HttpContext, Incoming>>::Error

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl<S, H, R, T> Service<HttpContext, Incoming> for Filter<S, H, R, T>

where S: Service<HttpContext, Incoming, Response = Response, Error = Infallible> + Send + Sync + 'static, H: HandlerWithoutRequest<T, Result<(), R>> + Clone + Send + Sync + 'static, R: IntoResponse + Send + Sync, T: Sync,

type Response = <S as Service<HttpContext, Incoming>>::Response

Responses given by the service.

type Error = <S as Service<HttpContext, Incoming>>::Error

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl<I, F, S, T> Service<HttpContext, Incoming> for FromFn<I, F, S, T>

where I: Service<HttpContext, Incoming, Response = Response, Error = Infallible> + Clone + Send + Sync + 'static, F: for<'r> MiddlewareHandlerFromFn<'r, T, S> + Clone + Sync, S: Clone + Sync,

type Response = <I as Service<HttpContext, Incoming>>::Response

Responses given by the service.

type Error = <I as Service<HttpContext, Incoming>>::Error

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl<H, S, T> Service<HttpContext, Incoming> for HandlerService<H, S, T>

where for<'r> H: Handler<T, S> + Clone + Send + Sync + 'r, S: Sync,

type Response = Response<RespBody>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl<I, F, S, T> Service<HttpContext, Incoming> for MapResponse<I, F, S, T>

where I: Service<HttpContext, Incoming, Response = Response, Error = Infallible> + Clone + Send + Sync + 'static, F: for<'r> MiddlewareHandlerMapResponse<'r, T, S> + Clone + Sync, S: Clone + Sync,

type Response = <I as Service<HttpContext, Incoming>>::Response

Responses given by the service.

type Error = <I as Service<HttpContext, Incoming>>::Error

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl Service<HttpContext, Incoming> for Router<()>

type Response = Response<RespBody>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.

impl<S, H, R, T> Service<HttpContext, Incoming> for Timeout<S, H, R, T>

where S: Service<HttpContext, Incoming, Response = Response, Error = Infallible> + Send + Sync + 'static, H: HandlerWithoutRequest<T, R> + Clone + Send + Sync + 'static, R: IntoResponse + Sync, T: Sync,

type Response = <S as Service<HttpContext, Incoming>>::Response

Responses given by the service.

type Error = <S as Service<HttpContext, Incoming>>::Error

Errors produced by the service.

async fn call<'s, 'cx>( &'s self, cx: &'cx mut HttpContext, req: Incoming ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.