Struct HttpConnectRequestAdapter 

#[non_exhaustive]
pub struct HttpConnectRequestAdapter<S> { /* private fields */ }

Adapt an HTTP Request to a protocol-independent ConnectRequest.

The original request, including its body, remains owned by this adapter while the inner connector establishes a connection. The successful connector input’s extension chain is then installed on the original request so selected routes and other connection metadata remain observable without requiring the body to be cloned.

Implementations

impl<S> HttpConnectRequestAdapter<S>

pub const fn new(inner: S) -> Self

Create a new HttpConnectRequestAdapter.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

Trait Implementations

impl<S: Clone> Clone for HttpConnectRequestAdapter<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for HttpConnectRequestAdapter<S>

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

Formats the value using the given formatter.

impl<S, Body> Service<Request<Body>> for HttpConnectRequestAdapter<S>

where S: ConnectorService<ConnectRequest>, Body: Send + 'static,

type Output = EstablishedClientConnection<<S as ConnectorService<ConnectRequest>>::Connection, Request<Body>>

The type of the output returned by the service.

type Error = ConnectionError

The type of error returned by the service.

async fn serve( &self, request: Request<Body>, ) -> Result<Self::Output, Self::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.