From 352c6ecffdbd46d89fc94253ad7d9e54507bfa00 Mon Sep 17 00:00:00 2001 From: Andrew Onuchowski Date: Wed, 21 Dec 2022 16:28:35 +0100 Subject: [PATCH] user iid added to broadcast msg --- src/bin/connection_pool.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/bin/connection_pool.rs b/src/bin/connection_pool.rs index 41d8c65..75e3300 100644 --- a/src/bin/connection_pool.rs +++ b/src/bin/connection_pool.rs @@ -46,9 +46,14 @@ impl ConnectionPool{ pub fn broadcast(&self, sender_iid: &u32, msg: &String) { let mut del_conns: Vec = Vec::new(); + let mut msg1: String; + + msg1 = format!("User {sender_iid}: ").parse().unwrap(); + msg1.push_str(msg); + for (iid, mut conn) in self.conns.lock().unwrap().iter() { if sender_iid.ne(iid){ - if conn.write_all(msg.as_bytes()).is_err() { + if conn.write_all(msg1.as_bytes()).is_err() { del_conns.push(*iid); continue; }