Struct EagerHttpProxyConnector 

pub struct EagerHttpProxyConnector<C, S> { /* private fields */ }

HTTP proxy CONNECT service which establishes the egress connection before acknowledging the CONNECT request.

Register it directly with an UpgradeLayer:

let connect = EagerHttpProxyConnector::new(connector, relay_service);
let layer = UpgradeLayer::new(
    executor,
    MethodMatcher::CONNECT,
    connect,
);

A successful response is returned only after connector established the requested egress connection. The established connection is carried across the HTTP upgrade and passed to relay_service together with the upgraded ingress connection as a BridgeIo.

Use LazyHttpProxyConnectReplyService together with a handler that establishes its own connection when the CONNECT request must be acknowledged before an egress connection can be made.

Connection policy belongs in the connector stack. For example, wrap the connector in a TimeoutLayer to bound the time spent establishing egress.

Implementations

impl<C, S> EagerHttpProxyConnector<C, S>

pub fn new(connector: C, relay_service: S) -> Self

Create an HTTP proxy CONNECT service that establishes egress before replying.

Trait Implementations

impl<C: Clone, S: Clone> Clone for EagerHttpProxyConnector<C, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug, S: Debug> Debug for EagerHttpProxyConnector<C, S>

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

Formats the value using the given formatter.

impl<C, S, Body> Service<Request<Body>> for EagerHttpProxyConnector<C, S>

where C: ConnectorService<ConnectRequest, Connection: Io + Unpin>, S: Service<BridgeIo<Upgraded, C::Connection>, Error: Into<BoxError>> + Clone, Body: Send + 'static,

type Output = UpgradeOutput<Request<Body>, Response>

The type of the output returned by the service.

type Error = Response

The type of error returned by the service.

async fn serve(&self, req: 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.