From be76c2aa51733a0cf495e92659fbcbe527f41149 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gustav=20S=C3=B6rn=C3=A4s?= Date: Sun, 6 Jun 2021 23:26:24 +0200 Subject: cargo fmt --- mumd/src/client.rs | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) (limited to 'mumd/src/client.rs') 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::>(None); - let (crypt_state_sender, crypt_state_receiver) = - mpsc::channel::(1); - let (packet_sender, packet_receiver) = - mpsc::unbounded_channel::>(); - let (ping_request_sender, ping_request_receiver) = - mpsc::unbounded_channel(); + let (crypt_state_sender, crypt_state_receiver) = mpsc::channel::(1); + let (packet_sender, packet_receiver) = mpsc::unbounded_channel::>(); + let (ping_request_sender, ping_request_receiver) = mpsc::unbounded_channel(); let event_queue = TcpEventQueue::new(); let state = Arc::new(RwLock::new(state)); -- cgit v1.2.1