gameServer2/src/server/network.rs
changeset 13419 81e0ed105f5d
parent 13416 cdf69667593b
child 13478 d79795acaa73
--- a/gameServer2/src/server/network.rs	Thu Jun 21 23:09:20 2018 +0200
+++ b/gameServer2/src/server/network.rs	Thu Jun 21 17:23:10 2018 -0400
@@ -17,7 +17,7 @@
 use utils;
 use protocol::{ProtocolDecoder, messages::*};
 use super::{
-    server::{HWServer, PendingMessage, Destination},
+    server::{HWServer},
     client::ClientId
 };
 
@@ -166,39 +166,13 @@
 
     fn flush_server_messages(&mut self) {
         debug!("{} pending server messages", self.server.output.len());
-        for PendingMessage(destination, msg) in self.server.output.drain(..) {
-            debug!("Message {:?} to {:?}", msg, destination);
-            match destination {
-                Destination::ToAll => {
-                    let msg_string = msg.to_raw_protocol();
-                    for (client_id, client) in self.clients.iter_mut() {
-                        client.send_string(&msg_string);
-                        self.pending.insert((client_id, NetworkClientState::NeedsWrite));
-                    }
-                },
-                Destination::ToSelf(id)  => {
-                    if let Some(client) = self.clients.get_mut(id) {
-                        client.send_msg(msg);
-                        self.pending.insert((id, NetworkClientState::NeedsWrite));
-                    }
-                }
-                Destination::ToOthers(id) => {
-                    let msg_string = msg.to_raw_protocol();
-                    for (client_id, client) in self.clients.iter_mut() {
-                        if client_id != id {
-                            client.send_string(&msg_string);
-                            self.pending.insert((client_id, NetworkClientState::NeedsWrite));
-                        }
-                    }
-                },
-                Destination::ToSelected(client_ids) => {
-                    let msg_string = msg.to_raw_protocol();
-                    for id in client_ids {
-                        if let Some(client) = self.clients.get_mut(id) {
-                            client.send_string(&msg_string);
-                            self.pending.insert((id, NetworkClientState::NeedsWrite));
-                        }
-                    }
+        for (clients, message) in self.server.output.drain(..) {
+            debug!("Message {:?} to {:?}", message, clients);
+            let msg_string = message.to_raw_protocol();
+            for client_id in clients {
+                if let Some(client) = self.clients.get_mut(client_id) {
+                    client.send_string(&msg_string);
+                    self.pending.insert((client_id, NetworkClientState::NeedsWrite));
                 }
             }
         }