accidentally sending messages twice

asyncversion
Kyle Johnsen 2022-03-16 00:30:59 -04:00
parent 5fa0855b9b
commit aa792c736c
1 changed files with 2 additions and 9 deletions

View File

@ -837,15 +837,8 @@ fn send_room_message(sender: Rc<RefCell<Client>>, message: &Vec<u8>, rooms: Rc<R
let room_ref = rooms_ref[&sender_ref.roomname].borrow(); let room_ref = rooms_ref[&sender_ref.roomname].borrow();
for (_k,v) in room_ref.clients.iter(){ for (_k,v) in room_ref.clients.iter(){
if !include_sender && *_k == sender_ref.id {
continue;
}
if *_k != sender_ref.id {
if *_k == sender_ref.id {
sender_ref.message_queue.extend(&write_buf);
sender_ref.notify.notify();
}else {
let mut temp_mut = v.borrow_mut(); let mut temp_mut = v.borrow_mut();
temp_mut.message_queue.extend_from_slice(&write_buf); temp_mut.message_queue.extend_from_slice(&write_buf);
temp_mut.notify.notify(); temp_mut.notify.notify();