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 {