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) -> Self

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>

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

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) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

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

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

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

The type of response returned by the service.

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

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Request<BodyIn>, ) -> Result<Self::Response, Self::Error>

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

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

Box this service to allow for dynamic dispatch.