dave/bft-crdt-experiment
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Only sending socket messages to other clients

Browse Source
This commit is contained in:
Dave Hrycyszyn
2024-06-06 13:16:55 +01:00
parent 1c610a9771
commit 309d3a8454
1 changed files with 8 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
side-watcher/src/main.rs
View File

@@ -1,6 +1,5 @@
use std::collections::HashMap;
use simple_websockets::{Event, Responder};
use std::collections::HashMap;
fn main() {
let event_hub = simple_websockets::launch(8080).expect("failed to listen on port 8080");
@@ -19,16 +18,15 @@ fn main() {
clients.remove(&client_id);
}
Event::Message(client_id, message) => {
println!(
"Received a message from client #{}: {:?}",
client_id, message
);
// retrieve this client's `Responder`:
// let responder = clients.get(&client_id).unwrap();
println!("\nReceived a message from client #{}", client_id);
let all_clients = clients.keys().collect::<Vec<_>>();
for client in all_clients {
let other_responder = clients.get(client).unwrap();
other_responder.send(message.clone());
if *client != client_id {
println!("Sending message to client #{}", client);
let responder = clients.get(client).unwrap();
responder.send(message.clone());
}
}
}
}