Struct HttpProxyConnectRelayServiceRequestMatcher 

pub struct HttpProxyConnectRelayServiceRequestMatcher<S = IoForwardService> { /* private fields */ }

Default matcher that can be used for Http proxy connects.

Request matches for an http proxy connect request return a HttpProxyConnectRelayServiceResponseMatcher instance which will match on any success responses…

Implementations

impl HttpProxyConnectRelayServiceRequestMatcher

pub fn default_with_exec(exec: Executor) -> Self

Create a HttpProxyConnectRelayServiceRequestMatcher whose default fallback relay observes graceful shutdown via the given Executor.

Prefer this over Self::default when you have an executor available — it lets the proxy connect bridges unwind cleanly on shutdown.

impl<S> HttpProxyConnectRelayServiceRequestMatcher<S>

pub fn new(relay_svc: S) -> Self

Create a new HttpProxyConnectRelayServiceRequestMatcher.

Trait Implementations

impl<S: Clone> Clone for HttpProxyConnectRelayServiceRequestMatcher<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 HttpProxyConnectRelayServiceRequestMatcher<S>

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

Formats the value using the given formatter.

impl Default for HttpProxyConnectRelayServiceRequestMatcher

fn default() -> Self

Returns the “default value” for a type.

impl<S, Body> ServiceMatcher<Request<Body>> for HttpProxyConnectRelayServiceRequestMatcher<S>

where S: Clone + Send + Sync + 'static, Body: Send + 'static,

type Service = HttpProxyConnectRelayServiceResponseMatcher<S>

The value returned when a match succeeds.

type Error = !

The error that can happen while evaluating the matcher.

type ModifiedInput = Request<Body>

Input returned by matching functions, it might be same as the original input but it can also be modified.

async fn match_service( &self, req: Request<Body>, ) -> Result<ServiceMatch<Self::ModifiedInput, Self::Service>, Self::Error>

Attempt to select a service for input.

async fn into_match_service( self, req: Request<Body>, ) -> Result<ServiceMatch<Self::ModifiedInput, Self::Service>, Self::Error>

Attempt to select a service for input, consuming the matcher.

fn boxed( self, ) -> BoxServiceMatcher<Input, Self::Service, Self::Error, Self::ModifiedInput>

where Self: Sized,

Box this matcher for dynamic dispatch.