Struct HttpProxyAddressService

pub struct HttpProxyAddressService<S> { /* private fields */ }

A Service which allows you to add a ProxyAddress to the Context in order to have your client connector make a connection via this proxy (e.g. by using HttpProxyConnectorLayer).

Implementations

impl<S> HttpProxyAddressService<S>

pub const fn new(inner: S, address: ProxyAddress) -> Self

Create a new HttpProxyAddressService that will create a service to set the given ProxyAddress.

pub const fn maybe(inner: S, address: Option<ProxyAddress>) -> Self

Create a new HttpProxyAddressService which will create a service that will set the given ProxyAddress if it is not None.

pub fn try_from_env_default(inner: S) -> Result<Self, OpaqueError>

Try to create a new HttpProxyAddressService which will establish a proxy connection over the environment variable HTTP_PROXY.

pub fn try_from_env(inner: S, key: impl AsRef<str>) -> Result<Self, OpaqueError>

Try to create a new HttpProxyAddressService which will establish a proxy connection over the given environment variable.

pub const fn preserve(self, preserve: bool) -> Self

Preserve the existing ProxyAddress in the context if it already exists.

pub fn set_preserve(&mut self, preserve: bool) -> &mut Self

Preserve the existing ProxyAddress in the context if it already exists.

Trait Implementations

impl<S: Clone> Clone for HttpProxyAddressService<S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for HttpProxyAddressService<S>

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

Formats the value using the given formatter.

impl<S, State, Request> Service<State, Request> for HttpProxyAddressService<S>

where S: Service<State, Request>, State: Clone + Send + Sync + 'static,

type Response = <S as Service<State, Request>>::Response

The type of response returned by the service.

type Error = <S as Service<State, Request>>::Error

The type of error returned by the service.

fn serve( &self, ctx: Context<State>, req: Request, ) -> impl Future<Output = Result<Self::Response, Self::Error>> + Send + '_

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.