Build with stable

Author: vi

src/client.rs

@@ -112,6 +112,7 @@ impl CommunicationActorState {
             },
             CommunicationActorMessage::ClientData(buf) => {
                 use rand::Rng;
+
                 let mut rng = rand::thread_rng();
 
                 // Try sending though a random port
@@ -147,7 +148,7 @@ pub async fn client(
     name: String,
     pco: PlayloadCommunicationOptions,
     cs: ClientSettings,
-) -> Result<!> {
+) -> Result<()> {
     let sendaddr = pco.sendto;
     let bindaddr = if let Some(x) = pco.bind {
         x

src/main.rs

@@ -95,7 +95,7 @@ struct ServerMetrics {
     snderr: u64,
 }
 
-async fn server(sa: SocketAddr) -> Result<!> {
+async fn server(sa: SocketAddr) -> Result<()> {
     use ttl_cache::TtlCache;
 
     type Registry = TtlCache<String, TtlCache<SocketAddr, ()>>;
@@ -235,7 +235,7 @@ async fn main() -> Result<()> {
         if opt.cs.keepalive_interval != 30 {
             eprintln!("--keepalive-interval is meaningless in server mode");
         }
-        server(sa).await?
+        server(sa).await?;
     } else {
         if opt.name.is_none() {
             Err("--name is required in client mode")?;
@@ -246,6 +246,7 @@ async fn main() -> Result<()> {
         let name = opt.name.unwrap();
         let sa = opt.client.unwrap();
 
-        client::client(sa, name, opt.pco, opt.cs).await?
+        client::client(sa, name, opt.pco, opt.cs).await?;
     }
+    Ok(())
 }