diff --git a/src/main.rs b/src/main.rs index 281818e..177dc89 100644 --- a/src/main.rs +++ b/src/main.rs @@ -6,7 +6,7 @@ mod systems; use crate::config::Settings; use crate::game::Game; -use crate::network::{listen, NetworkManager}; +use crate::network::listen; use async_std::sync::Arc; use async_std::{sync::channel, task}; use env_logger::Env; diff --git a/src/network.rs b/src/network.rs index cdae2fd..55ad94c 100644 --- a/src/network.rs +++ b/src/network.rs @@ -34,17 +34,19 @@ impl NetworkManager { self.connections.insert(conn.conn_id, conn); } - async fn send(&self, message: NetworkMessage) { + async fn send(&mut self, message: NetworkMessage) { let conn = self .connections - .get(&message.conn_id) + .get_mut(&message.conn_id) .expect("cant send message to an unregistered connection"); - conn.stream.send(message.data).await; + conn.stream + .send(message.data) + .await + .expect("could not send message to connection"); } } pub async fn listen( - net: Arc, bind: String, incoming: Sender, outgoing: Receiver,