From e4406676a28f2dfb756f8f9e38a4242166f19c0e Mon Sep 17 00:00:00 2001
From: Eskil Queseth <eskilq@kth.se>
Date: Wed, 14 Oct 2020 17:02:49 +0200
Subject: resolve some compiler warnings

---
 mumd/src/network/tcp.rs | 9 ++++-----
 mumd/src/network/udp.rs | 4 ++--
 2 files changed, 6 insertions(+), 7 deletions(-)

(limited to 'mumd/src/network')

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 {
-- 
cgit v1.2.1