summaryrefslogtreecommitdiff
path: root/game_server/src/scribble_group.rs
diff options
context:
space:
mode:
Diffstat (limited to 'game_server/src/scribble_group.rs')
-rw-r--r--game_server/src/scribble_group.rs10
1 files changed, 6 insertions, 4 deletions
diff --git a/game_server/src/scribble_group.rs b/game_server/src/scribble_group.rs
index 0d2c0f1..8980e7b 100644
--- a/game_server/src/scribble_group.rs
+++ b/game_server/src/scribble_group.rs
@@ -1,6 +1,7 @@
-use super::group::{Group, GroupId};
-use super::server::{UserId, GameClient,
- ClientSender, ClientReceiver};
+use crate::group::{Group, GroupId};
+use crate::server::{UserId, GameClient,
+ ClientSender, ClientReceiver,
+ GameServerError};
use std::collections::HashMap;
use std::sync::{Arc, Mutex};
@@ -27,13 +28,14 @@ impl Group for ScribbleGroup {
info!("a new group {}:'{}' runs now", self.id, self.name);
}
- fn add_client(&mut self, id: UserId, client: GameClient) {
+ fn add_client(&mut self, id: UserId, client: GameClient) -> Result<(), GameServerError> {
debug!("user {} joined the group {}:'{}'", id, self.id, self.name);
let (sen, rec) = client.split();
self.senders.lock().unwrap().insert(id, sen);
let senders_mutex = self.senders.clone();
let self_uid = id;
std::thread::spawn(move || Self::broadcast_clients(self_uid, rec, senders_mutex));
+ Ok(())
}
}