Fix unix schema bug.

jjeffcaii · jjeffcaii · commit f2a05bc95cb7 · 2020-06-11T22:34:06.000+08:00
diff --git a/rsocket-transport-unix/src/client.rs b/rsocket-transport-unix/src/client.rs
@@ -97,8 +97,8 @@ impl From<String> for UnixClientTransport {
 
 impl From<&str> for UnixClientTransport {
     fn from(addr: &str) -> UnixClientTransport {
-        let socket_addr: String = if addr.starts_with("tcp://") || addr.starts_with("TCP://") {
-            addr.chars().skip(6).collect::<String>()
+        let socket_addr: String = if addr.starts_with("unix://") || addr.starts_with("UNIX://") {
+            addr.chars().skip(7).collect::<String>()
         } else {
             addr.to_string()
         };
diff --git a/rsocket-transport-unix/src/server.rs b/rsocket-transport-unix/src/server.rs
@@ -51,11 +51,6 @@ impl Drop for UnixServerTransport {
         std::fs::remove_file(&self.addr.as_str()).unwrap();
     }
 }
-// impl From<SocketAddr> for UnixServerTransport {
-//     fn from(addr: SocketAddr) -> UnixServerTransport {
-//         UnixServerTransport::new(addr)
-//     }
-// }
 
 impl From<String> for UnixServerTransport {
     fn from(addr: String) -> UnixServerTransport {

Original file line number	Diff line number	Diff line change
`@@ -51,11 +51,6 @@ impl Drop for UnixServerTransport {`
`51`	`51`	`std::fs::remove_file(&self.addr.as_str()).unwrap();`
`52`	`52`	`}`
`53`	`53`	`}`
`54`		`-// impl From<SocketAddr> for UnixServerTransport {`
`55`		`-// fn from(addr: SocketAddr) -> UnixServerTransport {`
`56`		`-// UnixServerTransport::new(addr)`
`57`		`-// }`
`58`		`-// }`
`59`	`54`
`60`	`55`	`impl From<String> for UnixServerTransport {`
`61`	`56`	`fn from(addr: String) -> UnixServerTransport {`