pub fn new_connector_factory<T: Address + 'static>(
    resolver: AsyncResolver,
) -> impl ServiceFactory<
    Config = (),
    Request = Connect<T>,
    Response = Connection<T, TcpStream>,
    Error = ConnectError,
    InitError = (),
> + Clone {
    pipeline_factory(ResolverFactory::new(resolver)).and_then(TcpConnectorFactory::new())
}
/// Create TCP connector service factory.
Create TCP connector service factory.
Create TCP connector service factory .
pub fn new_connector_factory<T: Address + 'static>(
    resolver: AsyncResolver,
) -> impl ServiceFactory<
    Config = (),
    Request = Connect<T>,
    Response = Connection<T, TcpStream>,
    Error = ConnectError,
    InitError = (),
> + Clone {
    pipeline_factory(ResolverFactory::new(resolver)).and_then(TcpConnectorFactory::new())
}
pub fn new_connector_factory < T : Address + ' static > ( resolver : AsyncResolver , ) -> impl ServiceFactory < Config = ( ) , Request = Connect < T > , Response = Connection < T , TcpStream > , Error = ConnectError , InitError = ( ) , > + Clone { pipeline_factory ( ResolverFactory :: new ( resolver ) ) . and_then ( TcpConnectorFactory :: new ( ) ) }
Create TCP connector service factory.
Create TCP connector service factory .
resolver
AsyncResolver
resolver
AsyncResolver