From 36b5063637e3ca3e0be2f6cf59076ec0005f43f8 Mon Sep 17 00:00:00 2001 From: Hamcha Date: Sun, 4 Oct 2020 15:45:24 +0200 Subject: [PATCH] THIS WORKS BUT IS UGLY AND I DON'T CARE --- src/main.rs | 2 +- src/network.rs | 10 ++++++---- 2 files changed, 7 insertions(+), 5 deletions(-) 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,