feat(transport): Change channel connect to be async (#107)

This makes it so you can check if the initial connection
is established. Before this we used reconnect which would
lazily attempt to connect. So if you were trying to connect
to a non existant Server you wouldn't find out until after
you attempted your first RPC. This simplifies everything
by allowing you connect before creating the RPC client.

BREAKING CHANGE: `Endpoint::channel` was removed in favor of
an async `Endpoint::connect`.

Author: LucioFranco

tonic-build/src/client.rs

@@ -54,12 +54,13 @@ fn generate_connect(service_ident: &syn::Ident) -> TokenStream {
     quote! {
         impl #service_ident<tonic::transport::Channel> {
             /// Attempt to create a new client by connecting to a given endpoint.
-            pub fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
+            pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
             where
                 D: std::convert::TryInto<tonic::transport::Endpoint>,
                 D::Error: Into<StdError>,
             {
-                tonic::transport::Endpoint::new(dst).map(|c| Self::new(c.channel()))
+                let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
+                Ok(Self::new(conn))
             }
         }
     }

tonic-examples/src/authentication/client.rs

@@ -15,7 +15,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 HeaderValue::from_static("Bearer some-secret-token"),
             );
         })
-        .channel();
+        .connect()
+        .await?;
 
     let mut client = EchoClient::new(channel);
 

tonic-examples/src/gcp/client.rs

@@ -37,7 +37,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             headers.insert("authorization", header_value.clone());
         })
         .tls_config(&tls_config)
-        .channel();
+        .connect()
+        .await?;
 
     let mut service = PublisherClient::new(channel);
 

tonic-examples/src/helloworld/client.rs

@@ -6,7 +6,7 @@ use hello_world::{client::GreeterClient, HelloRequest};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let mut client = GreeterClient::connect("http://[::1]:50051")?;
+    let mut client = GreeterClient::connect("http://[::1]:50051").await?;
 
     let request = tonic::Request::new(HelloRequest {
         name: "Tonic".into(),

tonic-examples/src/multiplex/client.rs

@@ -12,7 +12,9 @@ use tonic::transport::Endpoint;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let channel = Endpoint::from_static("http://[::1]:50051").channel();
+    let channel = Endpoint::from_static("http://[::1]:50051")
+        .connect()
+        .await?;
 
     let mut greeter_client = GreeterClient::new(channel.clone());
     let mut echo_client = EchoClient::new(channel);

tonic-examples/src/routeguide/client.rs

@@ -91,7 +91,7 @@ async fn run_route_chat(client: &mut RouteGuideClient<Channel>) -> Result<(), Bo
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let mut client = RouteGuideClient::connect("http://[::1]:10000")?;
+    let mut client = RouteGuideClient::connect("http://[::1]:10000").await?;
 
     println!("*** SIMPLE RPC ***");
     let response = client

tonic-examples/src/tls/client.rs

@@ -17,7 +17,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     let channel = Channel::from_static("http://[::1]:50051")
         .tls_config(&tls)
-        .channel();
+        .connect()
+        .await?;
 
     let mut client = EchoClient::new(channel);
     let request = tonic::Request::new(EchoRequest {

tonic-examples/src/tls_client_auth/client.rs

@@ -21,8 +21,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     let channel = Channel::from_static("http://[::1]:50051")
         .tls_config(&tls)
-        .clone()
-        .channel();
+        .connect()
+        .await?;
 
     let mut client = EchoClient::new(channel);
 

tonic-interop/src/bin/client.rs

@@ -41,7 +41,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         );
     }
 
-    let channel = endpoint.channel();
+    let channel = endpoint.connect().await?;
 
     let mut client = client::TestClient::new(channel.clone());
     let mut unimplemented_client = client::UnimplementedClient::new(channel);

tonic/Cargo.toml

@@ -29,7 +29,6 @@ transport = [
     "hyper",
     "tokio",
     "tower",
-    "tower-reconnect",
     "tower-balance",
     "tower-load",
 ]
@@ -68,7 +67,6 @@ hyper = { version = "=0.13.0-alpha.4", features = ["unstable-stream"], optional
 tokio = { version = "=0.2.0-alpha.6", default-features = false, features = ["tcp"], optional = true }
 tower = { version = "=0.3.0-alpha.2", optional = true}
 tower-make = "=0.3.0-alpha.2a"
-tower-reconnect = { version = "=0.3.0-alpha.2", optional = true }
 tower-balance =  { version = "=0.3.0-alpha.2", optional = true }
 tower-load = { version = "=0.3.0-alpha.2", optional = true }