aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/network
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2020-12-26 22:33:10 +0100
committerGustav Sörnäs <gustav@sornas.net>2021-03-30 15:25:55 +0200
commit96ac028918baa1094374e823a2464016f7f20479 (patch)
tree91c8a87db33033dbd64d3d5a9ae4343488213085 /mumd/src/network
parent795e46c98616801c678bd0a403b08cb0fcd5ee43 (diff)
downloadmum-96ac028918baa1094374e823a2464016f7f20479.tar.gz
add todos
Diffstat (limited to 'mumd/src/network')
-rw-r--r--mumd/src/network/tcp.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs
index 47b1c20..09cd844 100644
--- a/mumd/src/network/tcp.rs
+++ b/mumd/src/network/tcp.rs
@@ -177,7 +177,7 @@ async fn authenticate(
msg.set_password(password);
}
msg.set_opus(true);
- sink.send(msg.into()).await.unwrap();
+ sink.send(msg.into()).await.unwrap(); //TODO handle panic
}
async fn send_pings(
@@ -189,7 +189,7 @@ async fn send_pings(
interval.tick().await;
trace!("Sending TCP ping");
let msg = msgs::Ping::new();
- packet_sender.send(msg.into()).unwrap();
+ packet_sender.send(msg.into()).unwrap(); //TODO handle panic
}
}
@@ -198,8 +198,8 @@ async fn send_packets(
packet_receiver: &mut mpsc::UnboundedReceiver<ControlPacket<Serverbound>>,
) {
loop {
- let packet = packet_receiver.recv().await.unwrap();
- sink.send(packet).await.unwrap();
+ let packet = packet_receiver.recv().await.unwrap(); //TODO handle panic
+ sink.send(packet).await.unwrap(); //TODO handle panic
}
}