Struct TlsConnector 

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

Rustls connector factory

Implementations

impl<A> TlsConnector<Connector<A>>

where A: Address,

pub fn new(config: ClientConfig) -> TlsConnector<Connector<A>>

pub fn connector<F, S>( self, f: impl IntoService<S, SharedCfg, Connect<A>>, ) -> TlsConnector<S>

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

Use connector to open connections.

Trait Implementations

impl<S> Clone for TlsConnector<S>

where S: Clone,

fn clone(&self) -> TlsConnector<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for TlsConnector<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<'a, A> From<&'a Arc<ClientConfig>> for TlsConnector<Connector<A>>

where A: Address,

fn from(config: &'a Arc<ClientConfig>) -> TlsConnector<Connector<A>>

Converts to this type from the input type.

impl<A> From<Arc<ClientConfig>> for TlsConnector<Connector<A>>

where A: Address,

fn from(config: Arc<ClientConfig>) -> TlsConnector<Connector<A>>

Converts to this type from the input type.

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.