Struct ExecuteRequest

pub struct ExecuteRequest<C: Connection<B> + PoolableConnection, B, K: Key> { /* 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, K: Key> ExecuteRequest<C, B, K>

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

Create a new request

pub fn into_parts(self) -> (Pooled<C, K>, 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, K: Debug + Key> Debug for ExecuteRequest<C, B, K>

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

Formats the value using the given formatter.

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

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

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

Responses given by the service.

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

Errors produced by the service.

type Future = MaybeErrorFuture<<S as Service<ExecuteRequest<C, B, K>>>::Future, <S as Service<ExecuteRequest<C, B, K>>>::Response, <S as Service<ExecuteRequest<C, B, K>>>::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, K>) -> Self::Future

Process the request and return the response asynchronously.

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

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

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

Responses given by the service.

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

Errors produced by the service.

type Future = MaybeErrorFuture<<S as Service<ExecuteRequest<C, B, K>>>::Future, <S as Service<ExecuteRequest<C, B, K>>>::Response, <S as Service<ExecuteRequest<C, B, K>>>::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, K>) -> Self::Future

Process the request and return the response asynchronously.

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

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

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, K> as Service<ExecuteRequest<C, B, K>>>::Response, <RequestExecutor<C, B, K> as Service<ExecuteRequest<C, B, K>>>::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, K>) -> Self::Future

Process the request and return the response asynchronously.

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

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

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

Responses given by the service.

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

Errors produced by the service.

type Future = <S as Service<ExecuteRequest<C, B, K>>>::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, K>) -> Self::Future

Process the request and return the response asynchronously.