diff options
author | metamuffin <metamuffin@disroot.org> | 2022-10-03 11:28:16 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2022-10-03 11:28:16 +0200 |
commit | 4e99a3325318c902cd78ea9f760f46d79acde5c0 (patch) | |
tree | cc2bc54f4a0eb27db2b5d38dfbb785c1e9b84bd6 /server | |
parent | fa44b02da29a0bd1b60026d4f6ffd6c9748a09da (diff) | |
download | keks-meet-4e99a3325318c902cd78ea9f760f46d79acde5c0.tar keks-meet-4e99a3325318c902cd78ea9f760f46d79acde5c0.tar.bz2 keks-meet-4e99a3325318c902cd78ea9f760f46d79acde5c0.tar.zst |
riesencommit (part 1)
Diffstat (limited to 'server')
-rw-r--r-- | server/src/room.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/server/src/room.rs b/server/src/room.rs index 61d978e..e0c2239 100644 --- a/server/src/room.rs +++ b/server/src/room.rs @@ -6,7 +6,7 @@ use crate::protocol::{ClientboundPacket, ServerboundPacket}; use futures_util::{SinkExt, StreamExt, TryFutureExt}; use log::{debug, error}; -use std::{collections::HashMap, sync::atomic::AtomicUsize}; +use std::{collections::HashMap, sync::atomic::AtomicUsize, time::Duration}; use tokio::sync::{mpsc, RwLock}; use warp::ws::{Message, WebSocket}; @@ -109,6 +109,8 @@ impl Room { ServerboundPacket::Ping => (), ServerboundPacket::Relay { recipient, message } => { let packet = ClientboundPacket::Message { sender, message }; + // Add some delay for testing scenarios with latency. + // tokio::time::sleep(Duration::from_millis(1000)).await; if let Some(recipient) = recipient { self.send_to_client(recipient, packet).await; } else { |