Method send_system_message

websockets/chat-actorless/src/server.rs:90–103

Send message to users in a room. `skip` is used to prevent messages triggered by a connection also being received by it.

(&self, room: &str, skip: ConnId, msg: impl Into<Msg>)

    ///
    /// `skip` is used to prevent messages triggered by a connection also being received by it.
    async fn send_system_message(&self, room: &str, skip: ConnId, msg: impl Into<Msg>) {
        if let Some(sessions) = self.rooms.get(room) {
            let msg = msg.into();

            for conn_id in sessions {
                if *conn_id != skip
                    && let Some(tx) = self.sessions.get(conn_id)
                {
                    // errors if client disconnected abruptly and hasn't been timed-out yet
                    let _ = tx.send(msg.clone());
                }
            }
        }
    }

    /// Send message to all other users in current room.
    ///