Struct Connect 

pub struct Connect<T> { /* private fields */ }

Request to resolve and connect to a remote address.

Implementations

impl<T> Connect<T>

where T: Address,

pub fn new(req: T) -> Connect<T>

Creates a connection request and derives a port from the host when present.

pub fn with(req: T, addr: SocketAddr) -> Connect<T>

Creates a request with a pre-resolved socket address.

The connector skips DNS resolution for this request.

pub fn set_port(self, port: u16) -> Connect<T>

Sets the port used when Address::port() does not provide one.

This replaces the port parsed from a host:port host by new(), which is zero if the host has none.

pub fn set_addr(self, addr: Option<SocketAddr>) -> Connect<T>

Sets one pre-resolved socket address.

pub fn set_addrs<I>(self, addrs: I) -> Connect<T>

where I: IntoIterator<Item = SocketAddr>,

Sets multiple pre-resolved socket addresses.

pub fn host(&self) -> &str

Returns the request host name.

pub fn port(&self) -> u16

Returns the port from Address::port(), or the one parsed from the host or set by set_port().

pub fn addrs(&self) -> ConnectAddrsIter<'_>

Iterates over the request’s pre-resolved addresses.

pub fn take_addrs(&mut self) -> ConnectTakeAddrsIter

Removes and returns the request’s pre-resolved addresses.

pub fn get_ref(&self) -> &T

Returns the original address value.

pub fn map_addr<F, R>(self, f: F) -> Connect<R>

where F: FnOnce(T) -> R,

Maps the original address value while preserving port and resolved addresses.

Trait Implementations

impl<T> Clone for Connect<T>

where T: Clone,

fn clone(&self) -> Connect<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Connect<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Display for Connect<T>

where T: Address,

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

Formats the value using the given formatter.

impl<T> Eq for Connect<T>

where T: Eq,

impl<T> From<T> for Connect<T>

where T: Address,

fn from(addr: T) -> Connect<T>

Converts to this type from the input type.

impl<T> Hash for Connect<T>

where T: Hash,

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<T> PartialEq for Connect<T>

where T: PartialEq,

fn eq(&self, other: &Connect<T>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<A> Service<SharedCfg, Connect<A>> for Connector<A>

where A: Address,

type Res = Io

Response produced by the service.

type Error = Error<ConnectError>

Error produced while checking readiness or processing a request.

async fn call( &self, req: Connect<A>, ctx: Ctx<'_, Connector<A>, SharedCfg>, ) -> Result<Io, <Connector<A> as Service<SharedCfg, Connect<A>>>::Error>

Processes a request and asynchronously returns the response.

async fn ready(&self, ctx: Ctx<'_, Self, St>) -> Result<(), Self::Error>

Waits until the service is ready to process a request.

async fn shutdown(&self, ctx: Ctx<'_, Self, St>)

Shuts down the service.

fn map<F, Res>(self, f: F) -> ServiceChain<Map<F, Self, Res>, St, Req>

where Self: Sized, F: Fn(Self::Res) -> Res,

Maps this service’s output to a different type, returning a new service.

fn map_err<F, E>(self, f: F) -> ServiceChain<MapErr<F, Self, E>, St, Req>

where Self: Sized, F: Fn(Self::Error) -> E,

Maps this service’s error to a different type, returning a new service.

fn and_then<Next, F>(self, f: F) -> ServiceChain<AndThen<Self, Next>, St, Req>

where Self: Sized, Next: Service<St, Self::Res, Error = Self::Error>, F: IntoService<Next, St, Self::Res>,

Calls another service after this service completes successfully.

fn pipeline(self, st: St) -> Pipeline<Req, Self::Res, Self::Error>

where Self: Sized + 'static, St: 'static, Req: 'static,

Wraps this service and its state in a Pipeline.

impl<F, A, S> Service<SharedCfg, Connect<A>> for SslConnector<S>

where F: Filter, A: Address, S: Service<SharedCfg, Connect<A>, Res = Io<F>, Error = Error<ConnectError>>,

type Res = Io<Layer<SslFilter, F>>

Response produced by the service.

type Error = Error<ConnectError>

Error produced while checking readiness or processing a request.

async fn call( &self, req: Connect<A>, ctx: Ctx<'_, SslConnector<S>, SharedCfg>, ) -> Result<<SslConnector<S> as Service<SharedCfg, Connect<A>>>::Res, <SslConnector<S> as Service<SharedCfg, Connect<A>>>::Error>

Processes a request and asynchronously returns the response.

async fn ready( &self, ctx: Ctx<'_, SslConnector<S>, SharedCfg>, ) -> Result<(), <SslConnector<S> as Service<SharedCfg, Connect<A>>>::Error>

Waits until the service is ready to process a request.

async fn shutdown(&self, ctx: Ctx<'_, SslConnector<S>, SharedCfg>)

Shuts down the service.

fn map<F, Res>(self, f: F) -> ServiceChain<Map<F, Self, Res>, St, Req>

where Self: Sized, F: Fn(Self::Res) -> Res,

Maps this service’s output to a different type, returning a new service.

fn map_err<F, E>(self, f: F) -> ServiceChain<MapErr<F, Self, E>, St, Req>

where Self: Sized, F: Fn(Self::Error) -> E,

Maps this service’s error to a different type, returning a new service.

fn and_then<Next, F>(self, f: F) -> ServiceChain<AndThen<Self, Next>, St, Req>

where Self: Sized, Next: Service<St, Self::Res, Error = Self::Error>, F: IntoService<Next, St, Self::Res>,

Calls another service after this service completes successfully.

fn pipeline(self, st: St) -> Pipeline<Req, Self::Res, Self::Error>

where Self: Sized + 'static, St: 'static, Req: 'static,

Wraps this service and its state in a Pipeline.

impl<F, A, S> Service<SharedCfg, Connect<A>> for TlsConnector<S>

where F: Filter, A: Address, S: Service<SharedCfg, Connect<A>, Res = Io<F>, Error = Error<ConnectError>>,

type Res = Io<Layer<TlsClientFilter, F>>

Response produced by the service.

type Error = Error<ConnectError>

Error produced while checking readiness or processing a request.

async fn call( &self, req: Connect<A>, ctx: Ctx<'_, TlsConnector<S>, SharedCfg>, ) -> Result<<TlsConnector<S> as Service<SharedCfg, Connect<A>>>::Res, <TlsConnector<S> as Service<SharedCfg, Connect<A>>>::Error>

Processes a request and asynchronously returns the response.

async fn ready( &self, ctx: Ctx<'_, TlsConnector<S>, SharedCfg>, ) -> Result<(), <TlsConnector<S> as Service<SharedCfg, Connect<A>>>::Error>

Waits until the service is ready to process a request.

async fn shutdown(&self, ctx: Ctx<'_, TlsConnector<S>, SharedCfg>)

Shuts down the service.

fn map<F, Res>(self, f: F) -> ServiceChain<Map<F, Self, Res>, St, Req>

where Self: Sized, F: Fn(Self::Res) -> Res,

Maps this service’s output to a different type, returning a new service.

fn map_err<F, E>(self, f: F) -> ServiceChain<MapErr<F, Self, E>, St, Req>

where Self: Sized, F: Fn(Self::Error) -> E,

Maps this service’s error to a different type, returning a new service.

fn and_then<Next, F>(self, f: F) -> ServiceChain<AndThen<Self, Next>, St, Req>

where Self: Sized, Next: Service<St, Self::Res, Error = Self::Error>, F: IntoService<Next, St, Self::Res>,

Calls another service after this service completes successfully.

fn pipeline(self, st: St) -> Pipeline<Req, Self::Res, Self::Error>

where Self: Sized + 'static, St: 'static, Req: 'static,

Wraps this service and its state in a Pipeline.

impl<T> StructuralPartialEq for Connect<T>

where T: PartialEq,