diff --git a/src/main.rs b/src/main.rs index 8fe4a09..f453371 100644 --- a/src/main.rs +++ b/src/main.rs @@ -52,26 +52,23 @@ impl MyApp { let score_arc = Arc::clone(&self.score); let x = self.x; let upgd_cost = self.upgd_cost; + let tx = network(); thread::spawn(move || { loop { println!("Send help send help send help Yasmina's holding me hostageeeeee"); thread::sleep(Duration::from_secs(1)); network(); - let tx = network(); + // let tx = network(); let current_score = { let guard = score_arc.lock().unwrap(); *guard }; - send_score(tx, x, upgd_cost, current_score); + send_score(tx.clone(), x, upgd_cost, current_score); } }); } - - - - } diff --git a/src/net.rs b/src/net.rs index 4acab98..15b7a5f 100644 --- a/src/net.rs +++ b/src/net.rs @@ -1,5 +1,3 @@ -pub mod networking { - use std::thread::sleep; use std::thread; use std::net::UdpSocket; @@ -13,8 +11,8 @@ pub fn network() -> Sender> { let tx: Sender> = tx.clone(); thread::spawn( move || { - let mut net_active = true; - while net_active { + let mut net_active = 1; + while net_active == 1 { let server_socket = UdpSocket::bind("0.0.0.0:0").unwrap(); let target = "100.127.105.90:4000"; let dat = rx.recv().unwrap(); @@ -27,7 +25,7 @@ pub fn network() -> Sender> { } if dat[0] == 0 { // code 0, kills thread - net_active = false; + net_active = 0; } if dat[0] == 1 { @@ -74,5 +72,4 @@ pub fn debug(tx: Sender>) -> Sender> { tx } -}