hatter/room-rs
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat: use TxSendMessage

Browse Source
This commit is contained in:
Hatter Jiang
2021-05-17 23:32:42 +08:00
parent 05693babdd
commit ea9f8788ad
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.rs
View File

@@ -196,7 +196,7 @@ fn handle_text_message(handle_context: &mut HandleContext, tx: &Tx, addr: Socket
if peer_client_id != client_id { if peer_client_id != client_id {
if let Some(peer_tx) = handle_context.peer_map.lock().unwrap().get(peer_client_addr) { if let Some(peer_tx) = handle_context.peer_map.lock().unwrap().get(peer_client_addr) {
sent_messages += 1; sent_messages += 1;
peer_tx.unbounded_send(Message::Text(mm.clone())).ok(); peer_tx.send_text(mm.clone());
} }
} }
} }
@@ -226,7 +226,7 @@ fn handle_text_message(handle_context: &mut HandleContext, tx: &Tx, addr: Socket
if let Some(client_map) = client_map { if let Some(client_map) = client_map {
if let Some(peer_client_addr) = client_map.get(peer_id) { if let Some(peer_client_addr) = client_map.get(peer_id) {
if let Some(peer_tx) = handle_context.peer_map.lock().unwrap().get(peer_client_addr) { if let Some(peer_tx) = handle_context.peer_map.lock().unwrap().get(peer_client_addr) {
peer_tx.unbounded_send(Message::Text(mm)).ok(); peer_tx.send_text(mm);
} }
RoomMessageDown::create_success_reply(format!("Message sent to: {}", peer_id)).send(tx); RoomMessageDown::create_success_reply(format!("Message sent to: {}", peer_id)).send(tx);
} else { } else {