exit immediately, do not handle accept failure

cmd/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "kaminari-cmd"
-version = "0.5.3"
+version = "0.5.4"
 edition = "2021"
 authors = ["zephyr <[email protected]>"]
 repository = "https://github.com/zephyrchien/kaminari/cmd"
@@ -9,10 +9,10 @@ readme = "README.md"
 license = "GPL-3.0"
 
 [dependencies]
-kaminari = "0.8.3"
-realm_io = "0.3.2"
-tokio = { version = "1", features = ["rt", "net", "macros"] }
 anyhow = "1"
+realm_io = "0.3.2"
+kaminari = { version = "0.9.0", features = ["ws", "tls"] }
+tokio = { version = "1.9", features = ["rt", "net", "macros"] }
 
 [[bin]]
 name = "kaminaric"

cmd/src/client.rs

@@ -41,7 +41,10 @@ async fn main() -> Result<()> {
                     Ok((stream, _)) => {
                         tokio::spawn(relay(stream, remote, $cc));
                     }
-                    Err(e) => eprintln!("accept error: {}", e),
+                    Err(e) => {
+                        eprintln!("accept error: {}", e);
+                        break;
+                    }
                 }
             }
         };
@@ -87,6 +90,8 @@ async fn main() -> Result<()> {
             run_ws_each!(client);
         }
     };
+
+    Ok(())
 }
 
 async fn relay<T>(mut local: TcpStream, remote: SocketAddr, client: Ref<T>) -> std::io::Result<()>

cmd/src/server.rs

@@ -51,7 +51,10 @@ async fn main() -> Result<()> {
                     Ok((stream, _)) => {
                         tokio::spawn(relay(stream, remote, $ac));
                     }
-                    Err(e) => eprintln!("accept error: {}", e),
+                    Err(e) => {
+                        eprintln!("accept error: {}", e);
+                        break;
+                    }
                 }
             }
         };
@@ -75,6 +78,8 @@ async fn main() -> Result<()> {
             run!(Ref::new(&server));
         }
     };
+
+    Ok(())
 }
 
 async fn relay<T: AsyncAccept<TcpStream>>(