chore: Remove redundant helper constructor (#1534)

* chore: Remove redundant helper constructor

* chore: Refactor endpoint to construct connector

Author: tottoto

tonic/src/transport/channel/endpoint.rs

@@ -301,18 +301,24 @@ impl Endpoint {
         self
     }
 
+    pub(crate) fn connector<C>(&self, c: C) -> service::Connector<C> {
+        #[cfg(feature = "tls")]
+        let connector = service::Connector::new(c, self.tls.clone());
+
+        #[cfg(not(feature = "tls"))]
+        let connector = service::Connector::new(c);
+
+        connector
+    }
+
     /// Create a channel from this config.
     pub async fn connect(&self) -> Result<Channel, Error> {
         let mut http = hyper::client::connect::HttpConnector::new();
         http.enforce_http(false);
         http.set_nodelay(self.tcp_nodelay);
         http.set_keepalive(self.tcp_keepalive);
 
-        #[cfg(feature = "tls")]
-        let connector = service::connector(http, self.tls.clone());
-
-        #[cfg(not(feature = "tls"))]
-        let connector = service::connector(http);
+        let connector = self.connector(http);
 
         if let Some(connect_timeout) = self.connect_timeout {
             let mut connector = hyper_timeout::TimeoutConnector::new(connector);
@@ -333,11 +339,7 @@ impl Endpoint {
         http.set_nodelay(self.tcp_nodelay);
         http.set_keepalive(self.tcp_keepalive);
 
-        #[cfg(feature = "tls")]
-        let connector = service::connector(http, self.tls.clone());
-
-        #[cfg(not(feature = "tls"))]
-        let connector = service::connector(http);
+        let connector = self.connector(http);
 
         if let Some(connect_timeout) = self.connect_timeout {
             let mut connector = hyper_timeout::TimeoutConnector::new(connector);
@@ -362,11 +364,7 @@ impl Endpoint {
         C::Future: Send + 'static,
         crate::Error: From<C::Error> + Send + 'static,
     {
-        #[cfg(feature = "tls")]
-        let connector = service::connector(connector, self.tls.clone());
-
-        #[cfg(not(feature = "tls"))]
-        let connector = service::connector(connector);
+        let connector = self.connector(connector);
 
         if let Some(connect_timeout) = self.connect_timeout {
             let mut connector = hyper_timeout::TimeoutConnector::new(connector);
@@ -391,12 +389,7 @@ impl Endpoint {
         C::Future: Send + 'static,
         crate::Error: From<C::Error> + Send + 'static,
     {
-        #[cfg(feature = "tls")]
-        let connector = service::connector(connector, self.tls.clone());
-
-        #[cfg(not(feature = "tls"))]
-        let connector = service::connector(connector);
-
+        let connector = self.connector(connector);
         Channel::new(connector, self.clone())
     }
 

tonic/src/transport/service/connector.rs

@@ -8,16 +8,6 @@ use std::task::{Context, Poll};
 use tower::make::MakeConnection;
 use tower_service::Service;
 
-#[cfg(not(feature = "tls"))]
-pub(crate) fn connector<C>(inner: C) -> Connector<C> {
-    Connector::new(inner)
-}
-
-#[cfg(feature = "tls")]
-pub(crate) fn connector<C>(inner: C, tls: Option<TlsConnector>) -> Connector<C> {
-    Connector::new(inner, tls)
-}
-
 pub(crate) struct Connector<C> {
     inner: C,
     #[cfg(feature = "tls")]
@@ -34,7 +24,7 @@ impl<C> Connector<C> {
     }
 
     #[cfg(feature = "tls")]
-    fn new(inner: C, tls: Option<TlsConnector>) -> Self {
+    pub(crate) fn new(inner: C, tls: Option<TlsConnector>) -> Self {
         Self { inner, tls }
     }
 

tonic/src/transport/service/discover.rs

@@ -1,4 +1,3 @@
-use super::super::service;
 use super::connection::Connection;
 use crate::transport::Endpoint;
 
@@ -38,12 +37,8 @@ impl<K: Hash + Eq + Clone> Stream for DynamicServiceStream<K> {
                     http.set_keepalive(endpoint.tcp_keepalive);
                     http.set_connect_timeout(endpoint.connect_timeout);
                     http.enforce_http(false);
-                    #[cfg(feature = "tls")]
-                    let connector = service::connector(http, endpoint.tls.clone());
 
-                    #[cfg(not(feature = "tls"))]
-                    let connector = service::connector(http);
-                    let connection = Connection::lazy(connector, endpoint);
+                    let connection = Connection::lazy(endpoint.connector(http), endpoint);
                     let change = Ok(Change::Insert(k, connection));
                     Poll::Ready(Some(change))
                 }

tonic/src/transport/service/mod.rs

@@ -13,7 +13,7 @@ mod user_agent;
 
 pub(crate) use self::add_origin::AddOrigin;
 pub(crate) use self::connection::Connection;
-pub(crate) use self::connector::connector;
+pub(crate) use self::connector::Connector;
 pub(crate) use self::discover::DynamicServiceStream;
 pub(crate) use self::executor::SharedExec;
 pub(crate) use self::grpc_timeout::GrpcTimeout;