aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/client.rs
diff options
context:
space:
mode:
Diffstat (limited to 'mumd/src/client.rs')
-rw-r--r--mumd/src/client.rs13
1 files changed, 5 insertions, 8 deletions
diff --git a/mumd/src/client.rs b/mumd/src/client.rs
index ba9cad4..9e8ca18 100644
--- a/mumd/src/client.rs
+++ b/mumd/src/client.rs
@@ -1,10 +1,10 @@
-use crate::{command, network::tcp::TcpEventQueue};
use crate::error::ClientError;
use crate::network::{tcp, udp, ConnectionInfo};
use crate::state::State;
+use crate::{command, network::tcp::TcpEventQueue};
use futures_util::{select, FutureExt};
-use mumble_protocol::{Serverbound, control::ControlPacket, crypt::ClientCryptState};
+use mumble_protocol::{control::ControlPacket, crypt::ClientCryptState, Serverbound};
use mumlib::command::{Command, CommandResponse};
use std::sync::{Arc, RwLock};
use tokio::sync::{mpsc, watch};
@@ -18,12 +18,9 @@ pub async fn handle(
) -> Result<(), ClientError> {
let (connection_info_sender, connection_info_receiver) =
watch::channel::<Option<ConnectionInfo>>(None);
- let (crypt_state_sender, crypt_state_receiver) =
- mpsc::channel::<ClientCryptState>(1);
- let (packet_sender, packet_receiver) =
- mpsc::unbounded_channel::<ControlPacket<Serverbound>>();
- let (ping_request_sender, ping_request_receiver) =
- mpsc::unbounded_channel();
+ let (crypt_state_sender, crypt_state_receiver) = mpsc::channel::<ClientCryptState>(1);
+ let (packet_sender, packet_receiver) = mpsc::unbounded_channel::<ControlPacket<Serverbound>>();
+ let (ping_request_sender, ping_request_receiver) = mpsc::unbounded_channel();
let event_queue = TcpEventQueue::new();
let state = Arc::new(RwLock::new(state));