Lines Matching refs:my_id
52 let my_id = NEXT_USER_ID.fetch_add(1, Ordering::Relaxed); in user_connected() localVariable
54 eprintln!("new chat user: {}", my_id); in user_connected()
69 users.lock().await.insert(my_id, tx); in user_connected()
83 eprintln!("websocket error(uid={}): {}", my_id, e); in user_connected()
87 user_message(my_id, msg, &users).await; in user_connected()
92 user_disconnected(my_id, &users2).await; in user_connected()
95 async fn user_message(my_id: usize, msg: Message, users: &Users) { in user_message()
103 let new_msg = format!("<User#{}>: {}", my_id, msg); in user_message()
110 if my_id != uid { in user_message()
120 async fn user_disconnected(my_id: usize, users: &Users) { in user_disconnected()
121 eprintln!("good bye user: {}", my_id); in user_disconnected()
124 users.lock().await.remove(&my_id); in user_disconnected()