caesar-cli/src/cli/args.rs

@@ -79,7 +79,7 @@ impl Args {
                 name,
             }) => {
                 println!("Receive for {name:?}");
-                receiver::start_receiver(
+                let _ = receiver::start_receiver(
                     ".".to_string(),
                     relay.as_deref().unwrap_or(&cfg.app_origin),
                     name,

caesar-core/src/receiver/mod.rs

@@ -36,7 +36,7 @@ pub async fn start_receiver(filepath: String, relay: &str, name: &str) -> Result
     if let Err(relay_err) = start_ws_com(filepath, relay, res.relay_room_id.as_str()).await {
         debug!("Failed to connect remote: {relay_err}");
     }
-    let _success = http_client::download_success(http_url.as_str(), name)
+    http_client::download_success(http_url.as_str(), name)
         .await
         .map_err(|e| anyhow!("Failed to download success: {}", e))?;
 

caesar-core/src/sender/client.rs

@@ -22,8 +22,6 @@ use std::{
     path::Path,
     time::Duration,
 };
-// use tokio::sync::mpsc;
-use tokio::sync::mpsc;
 use tokio::{io::AsyncReadExt, task::JoinHandle, time::sleep};
 use tokio_tungstenite::tungstenite::{protocol::Message as WebSocketMessage, Error};
 use tracing::{debug, error};