Struct ExecuteRequest

pub struct ExecuteRequest<C: Connection<B> + PoolableConnection, B> { /* private fields */ }

Available on crate feature client only.

Couples the connection with the http request.

This allows downstream services to access both the request and connection – they are needed in tandem to send the request. This also means that middleware can implement tower::Service on tower::Service<ExecuteRequest<C, B>> to modify the request before it is sent in the context of the connection.

See crate::service::SetHostHeader for an example of a middleware that modifies the request before it is sent in the context of the connection.

Implementations

impl<C: Connection<B> + PoolableConnection, B> ExecuteRequest<C, B>

pub fn new(conn: Pooled<C>, request: Request<B>) -> Self

Create a new request

pub fn into_parts(self) -> (Pooled<C>, Request<B>)

Split the request into its parts.

pub fn connection(&self) -> &C

A reference to the connection.

pub fn request(&self) -> &Request<B>

A reference to the request.

pub fn request_mut(&mut self) -> &mut Request<B>

A mutable reference to the request.

Trait Implementations

impl<C: Debug + Connection<B> + PoolableConnection, B: Debug> Debug for ExecuteRequest<C, B>

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

Formats the value using the given formatter.

impl<S, C, B> Service<ExecuteRequest<C, B>> for Http1ChecksService<S, C, B>

where S: Service<ExecuteRequest<C, B>, Error = Error>, C: Connection<B> + PoolableConnection,

type Response = <S as Service<ExecuteRequest<C, B>>>::Response

Responses given by the service.

type Error = <S as Service<ExecuteRequest<C, B>>>::Error

Errors produced by the service.

type Future = MaybeErrorFuture<<S as Service<ExecuteRequest<C, B>>>::Future, <S as Service<ExecuteRequest<C, B>>>::Response, <S as Service<ExecuteRequest<C, B>>>::Error>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: ExecuteRequest<C, B>) -> Self::Future

Process the request and return the response asynchronously.

impl<S, C, B> Service<ExecuteRequest<C, B>> for Http2ChecksService<S, C, B>

where S: Service<ExecuteRequest<C, B>, Error = Error>, C: Connection<B> + PoolableConnection,

type Response = <S as Service<ExecuteRequest<C, B>>>::Response

Responses given by the service.

type Error = <S as Service<ExecuteRequest<C, B>>>::Error

Errors produced by the service.

type Future = MaybeErrorFuture<<S as Service<ExecuteRequest<C, B>>>::Future, <S as Service<ExecuteRequest<C, B>>>::Response, <S as Service<ExecuteRequest<C, B>>>::Error>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: ExecuteRequest<C, B>) -> Self::Future

Process the request and return the response asynchronously.

impl<C, B> Service<ExecuteRequest<C, B>> for RequestExecutor<C, B>

where C: Connection<B> + PoolableConnection, B: Body + Unpin + Send + 'static,

type Response = Response<<C as Connection<B>>::ResBody>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<RequestExecutor<C, B> as Service<ExecuteRequest<C, B>>>::Response, <RequestExecutor<C, B> as Service<ExecuteRequest<C, B>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: ExecuteRequest<C, B>) -> Self::Future

Process the request and return the response asynchronously.

impl<S, B, C> Service<ExecuteRequest<C, B>> for SetHostHeader<S>

where S: Service<ExecuteRequest<C, B>>, C: Connection<B> + PoolableConnection,

type Response = <S as Service<ExecuteRequest<C, B>>>::Response

Responses given by the service.

type Error = <S as Service<ExecuteRequest<C, B>>>::Error

Errors produced by the service.

type Future = <S as Service<ExecuteRequest<C, B>>>::Future

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: ExecuteRequest<C, B>) -> Self::Future

Process the request and return the response asynchronously.