diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2021-06-06 23:26:24 +0200 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2021-06-06 23:26:24 +0200 |
| commit | be76c2aa51733a0cf495e92659fbcbe527f41149 (patch) | |
| tree | 617fb1caa999c076a45233b4bedea6a78192db25 /mumd/src/client.rs | |
| parent | 7fc5a1a36404ee4cbc09d20c955e6edd3d2ac523 (diff) | |
| download | mum-be76c2aa51733a0cf495e92659fbcbe527f41149.tar.gz | |
cargo fmt
Diffstat (limited to 'mumd/src/client.rs')
| -rw-r--r-- | mumd/src/client.rs | 13 |
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)); |
