diff options
| author | metamuffin <metamuffin@disroot.org> | 2024-03-18 10:46:39 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2024-03-18 10:46:39 +0100 |
| commit | 7d410d53274fdd6840261c286bc2785222256436 (patch) | |
| tree | 807ac6f960f4c8c9d026111311ec8d8490002157 /server/src/logic.rs | |
| parent | 0825cb66e63a0af09f0c0945542d412091010f73 (diff) | |
| download | keks-meet-7d410d53274fdd6840261c286bc2785222256436.tar keks-meet-7d410d53274fdd6840261c286bc2785222256436.tar.bz2 keks-meet-7d410d53274fdd6840261c286bc2785222256436.tar.zst | |
clippy
Diffstat (limited to 'server/src/logic.rs')
| -rw-r--r-- | server/src/logic.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/server/src/logic.rs b/server/src/logic.rs index b16e605..b660914 100644 --- a/server/src/logic.rs +++ b/server/src/logic.rs @@ -17,6 +17,7 @@ use std::{ use tokio::sync::{mpsc::Sender, RwLock}; use warp::ws::WebSocket; +#[allow(clippy::redundant_closure)] static CLIENTS: LazyLock<RwLock<HashMap<Client, Sender<ClientboundPacket>>>> = LazyLock::new(|| Default::default()); @@ -141,7 +142,7 @@ impl State { let mut w = self.watches.write().await; let r = self.rooms.read().await; - for e in list.to_owned() { + for e in list.iter().cloned() { w.entry(e.to_string()).or_default().insert(client); if let Some(r) = r.get(&e) { client @@ -170,7 +171,7 @@ impl State { impl Client { pub async fn send(&self, packet: ClientboundPacket) { - if let Some(s) = CLIENTS.read().await.get(&self) { + if let Some(s) = CLIENTS.read().await.get(self) { s.send(packet).await.unwrap(); } else { warn!("invalid recipient {self:?}") |