Struct Connector 

pub struct Connector<A: Address, T> { /* private fields */ }

Http2 client connector

Implementations

impl<A, T> Connector<A, T>

where A: Address, T: ServiceFactory<Connect<A>, SharedCfg, Error = ConnectError>, IoBoxed: From<T::Response>,

pub fn new<F>(connector: F) -> Connector<A, T>

where F: IntoServiceFactory<T, Connect<A>, SharedCfg>,

Create new http2 connector

impl<A, T> Connector<A, T>

where A: Address,

pub fn scheme(&mut self, scheme: Scheme) -> &mut Self

Set scheme

pub fn connector<U, F>(&self, connector: F) -> Connector<A, U>

where F: IntoServiceFactory<U, Connect<A>, SharedCfg>, U: ServiceFactory<Connect<A>, SharedCfg, Error = ConnectError>, IoBoxed: From<U::Response>,

Use custom connector

Trait Implementations

impl<A: Debug + Address, T: Debug> Debug for Connector<A, T>

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

Formats the value using the given formatter.

impl<A> Default for Connector<A, Connector<A>>

where A: Address,

fn default() -> Self

Create new h2 connector

impl<A, T> ServiceFactory<A, SharedCfg> for Connector<A, T>

where A: Address, T: ServiceFactory<Connect<A>, SharedCfg, Error = ConnectError>, IoBoxed: From<T::Response>,

type Response = SimpleClient

Responses given by the created services.

type Error = ClientError

Errors produced by the created services.

type InitError = <T as ServiceFactory<Connect<A>, SharedCfg>>::InitError

Errors potentially raised while building a service.

type Service = ConnectorService<A, <T as ServiceFactory<Connect<A>, SharedCfg>>::Service>

The kind of Service created by this factory.

async fn create(&self, cfg: SharedCfg) -> Result<Self::Service, Self::InitError>

Create and return a new service value asynchronously.

async fn pipeline( &self, cfg: Cfg, ) -> Result<Pipeline<Self::Service>, Self::InitError>

where Self: Sized,

Create and return a new service value asynchronously and wrap into a container

fn map<F, Res>( self, f: F, ) -> ServiceChainFactory<MapFactory<Self, F, Req, Res, Cfg>, Req, Cfg>

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

Map this service’s output to a different type, returning a new service of the resulting type.

fn map_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapErrFactory<Self, Req, Cfg, F, E>, Req, Cfg>

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

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

fn map_init_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapInitErr<Self, Req, Cfg, F, E>, Req, Cfg>

where Self: Sized, F: Fn(Self::InitError) -> E + Clone,

Map this factory’s init error to a different error, returning a new service.