Struct ProxyConnector 

pub struct ProxyConnector { /* private fields */ }

A tower_service::Service<Uri> that connects through an HTTP CONNECT proxy.

On call(target_uri) it:

1. Opens a TCP connection to the configured proxy.
2. Sends CONNECT target_host:target_port HTTP/1.1 with optional Proxy-Authorization: Basic ... when credentials are present in the proxy URI.
3. Reads the proxy’s HTTP/1.1 200 ... response.
4. Returns the raw TCP stream, ready for further use (plain HTTP or TLS).

Implementations

impl ProxyConnector

pub fn new(proxy_uri: Uri, connect_timeout: Option<Duration>) -> Self

Create a new ProxyConnector.

proxy_uri is the address of the HTTP CONNECT proxy server (e.g. http://proxy.example.com:8080). User/password credentials in the URI userinfo are automatically extracted and used as Proxy-Authorization.

Trait Implementations

impl Clone for ProxyConnector

fn clone(&self) -> ProxyConnector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProxyConnector

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

Formats the value using the given formatter.

impl Service<Uri> for ProxyConnector

type Response = TokioIo<TcpStream>

Responses given by the service.

type Error = OxiHttpError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<ProxyConnector as Service<Uri>>::Response, <ProxyConnector as Service<Uri>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, uri: Uri) -> Self::Future

Process the request and return the response asynchronously.