diff options
| author | Eskil Queseth <eskilq@kth.se> | 2020-10-14 17:02:49 +0200 |
|---|---|---|
| committer | Eskil Queseth <eskilq@kth.se> | 2020-10-14 17:02:49 +0200 |
| commit | e4406676a28f2dfb756f8f9e38a4242166f19c0e (patch) | |
| tree | 7f3be459af5be2a8e94952de622d8e093520a56e /mumd/src/network | |
| parent | a42eea8af353d15e1ffba287fa47ad774c31aef1 (diff) | |
| download | mum-e4406676a28f2dfb756f8f9e38a4242166f19c0e.tar.gz | |
resolve some compiler warnings
Diffstat (limited to 'mumd/src/network')
| -rw-r--r-- | mumd/src/network/tcp.rs | 9 | ||||
| -rw-r--r-- | mumd/src/network/udp.rs | 4 |
2 files changed, 6 insertions, 7 deletions
diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs index 0aca19e..1e0feee 100644 --- a/mumd/src/network/tcp.rs +++ b/mumd/src/network/tcp.rs @@ -16,7 +16,6 @@ use tokio::sync::{mpsc, watch}; use tokio::time::{self, Duration}; use tokio_tls::{TlsConnector, TlsStream}; use tokio_util::codec::{Decoder, Framed}; -use futures_util::core_reexport::cell::RefCell; type TcpSender = SplitSink< Framed<TlsStream<TcpStream>, ControlCodec<Serverbound, Clientbound>>, @@ -44,7 +43,7 @@ pub async fn handle( .await; // Handshake (omitting `Version` message for brevity) - let mut state_lock = state.lock().unwrap(); + let state_lock = state.lock().unwrap(); authenticate(&mut sink, state_lock.username().unwrap().to_string()).await; let phase_watcher = state_lock.phase_receiver(); let packet_sender = state_lock.packet_sender(); @@ -102,7 +101,7 @@ async fn send_pings( let (tx, rx) = oneshot::channel(); let phase_transition_block = async { while !matches!(phase_watcher.recv().await.unwrap(), StatePhase::Disconnected) {} - tx.send(true); + tx.send(true).unwrap(); }; let mut interval = time::interval(Duration::from_secs(delay_seconds)); @@ -141,7 +140,7 @@ async fn send_packets( let (tx, rx) = oneshot::channel(); let phase_transition_block = async { while !matches!(phase_watcher.recv().await.unwrap(), StatePhase::Disconnected) {} - tx.send(true); + tx.send(true).unwrap(); }; let main_block = async { @@ -191,7 +190,7 @@ async fn listen( let (tx, rx) = oneshot::channel(); let phase_transition_block = async { while !matches!(phase_watcher.recv().await.unwrap(), StatePhase::Disconnected) {} - tx.send(true); + tx.send(true).unwrap(); }; let listener_block = async { diff --git a/mumd/src/network/udp.rs b/mumd/src/network/udp.rs index ab4ca1d..a757a2b 100644 --- a/mumd/src/network/udp.rs +++ b/mumd/src/network/udp.rs @@ -75,7 +75,7 @@ async fn listen( let (tx, rx) = oneshot::channel(); let phase_transition_block = async { while !matches!(phase_watcher.recv().await.unwrap(), StatePhase::Disconnected) {} - tx.send(true); + tx.send(true).unwrap(); }; let main_block = async { @@ -185,7 +185,7 @@ async fn send_voice( let (tx, rx) = oneshot::channel(); let phase_transition_block = async { while !matches!(phase_watcher.recv().await.unwrap(), StatePhase::Disconnected) {} - tx.send(true); + tx.send(true).unwrap(); }; let main_block = async { |
