Merge pull request #128 from Tim-Zhang/example-adapt-new-unix-domain-protocol

example: Use new domain socket protocol of ttrpc

Author: Tim-Zhang

example/async-client.rs

@@ -11,7 +11,7 @@ use ttrpc::r#async::Client;
 
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
-    let c = Client::connect("unix:///tmp/1").unwrap();
+    let c = Client::connect("unix://@/tmp/1").unwrap();
     let hc = health_ttrpc::HealthClient::new(c.clone());
     let ac = agent_ttrpc::AgentServiceClient::new(c);
 

example/async-server.rs

@@ -94,7 +94,7 @@ async fn main() {
     let aservice = agent_ttrpc::create_agent_service(a);
 
     let mut server = Server::new()
-        .bind("unix:///tmp/1")
+        .bind("unix://@/tmp/1")
         .unwrap()
         .register_service(hservice)
         .register_service(aservice);

example/client.rs

@@ -20,7 +20,7 @@ use ttrpc::client::Client;
 use ttrpc::context::{self, Context};
 
 fn main() {
-    let c = Client::connect("unix:///tmp/1").unwrap();
+    let c = Client::connect("unix://@/tmp/1").unwrap();
     let hc = health_ttrpc::HealthClient::new(c.clone());
     let ac = agent_ttrpc::AgentServiceClient::new(c);
 

example/server.rs

@@ -90,7 +90,7 @@ fn main() {
     let aservice = agent_ttrpc::create_agent_service(a);
 
     let mut server = Server::new()
-        .bind("unix:///tmp/1")
+        .bind("unix://@/tmp/1")
         .unwrap()
         .register_service(hservice)
         .register_service(aservice);