From ea9f8788adaf2e2f203cf4d6dc74f9ff4143a00d Mon Sep 17 00:00:00 2001 From: "Hatter Jiang@Pixelbook" Date: Mon, 17 May 2021 23:32:42 +0800 Subject: [PATCH] feat: use TxSendMessage --- src/main.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main.rs b/src/main.rs index efa24ee..e460d3a 100644 --- a/src/main.rs +++ b/src/main.rs @@ -196,7 +196,7 @@ fn handle_text_message(handle_context: &mut HandleContext, tx: &Tx, addr: Socket if peer_client_id != client_id { if let Some(peer_tx) = handle_context.peer_map.lock().unwrap().get(peer_client_addr) { 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(peer_client_addr) = client_map.get(peer_id) { 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); } else {