Struct HttpConnector

pub struct HttpConnector<S, I1 = (), I2 = ()> { /* private fields */ }

A Service which establishes an HTTP Connection.

Implementations

impl<S> HttpConnector<S>

pub const fn new(inner: S) -> HttpConnector<S>

Create a new HttpConnector.

impl<S, I1, I2> HttpConnector<S, I1, I2>

pub fn with_jit_req_inspector<T>( self, http_req_inspector: T, ) -> HttpConnector<S, T, I2>

Add a http request inspector that will run just after the inner http connector has finished but before the http handshake

pub fn with_svc_req_inspector<T>( self, http_req_inspector: T, ) -> HttpConnector<S, I1, T>

Add a http request inspector that will run just before doing the actual http request

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, I1, I2> Clone for HttpConnector<S, I1, I2>

where S: Clone, I1: Clone, I2: Clone,

fn clone(&self) -> HttpConnector<S, I1, I2>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, I1, I2> Debug for HttpConnector<S, I1, I2>

where S: Debug, I1: Debug, I2: Debug,

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

Formats the value using the given formatter.

impl<S, I1, I2, BodyIn, BodyOut> Service<Request<BodyIn>> for HttpConnector<S, I1, I2>

where I1: RequestInspector<Request<BodyIn>, RequestOut = Request<BodyIn>>, <I1 as RequestInspector<Request<BodyIn>>>::Error: Into<Box<dyn Error + Sync + Send>>, I2: RequestInspector<Request<BodyIn>, RequestOut = Request<BodyOut>> + Clone, <I2 as RequestInspector<Request<BodyIn>>>::Error: Into<Box<dyn Error + Sync + Send>>, S: ConnectorService<Request<BodyIn>>, <S as ConnectorService<Request<BodyIn>>>::Connection: Stream + Unpin, <S as ConnectorService<Request<BodyIn>>>::Error: Into<Box<dyn Error + Sync + Send>>, BodyIn: Body + Unpin + Send + 'static, <BodyIn as Body>::Data: Send + 'static, <BodyIn as Body>::Error: Into<Box<dyn Error + Sync + Send>>, BodyOut: Body + Unpin + Send + 'static, <BodyOut as Body>::Data: Send + 'static, <BodyOut as Body>::Error: Into<Box<dyn Error + Sync + Send>>,

type Response = EstablishedClientConnection<HttpClientService<BodyOut, I2>, <I1 as RequestInspector<Request<BodyIn>>>::RequestOut>

The type of response returned by the service.

type Error = Box<dyn Error + Sync + Send>

The type of error returned by the service.

async fn serve( &self, ctx: Context, req: Request<BodyIn>, ) -> Result<<HttpConnector<S, I1, I2> as Service<Request<BodyIn>>>::Response, <HttpConnector<S, I1, I2> as Service<Request<BodyIn>>>::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.