diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2020-10-29 21:28:12 +0100 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2020-10-29 21:28:12 +0100 |
| commit | 4010e0f5abb28bae3207c78dba74f0896eedea51 (patch) | |
| tree | 2e1c215705d04f86e47a1a0a9015dfd6ed6feeaf /mumd/src/command.rs | |
| parent | 3e7e375e65760a03b6692106ab0ed806ca65e470 (diff) | |
| download | mum-4010e0f5abb28bae3207c78dba74f0896eedea51.tar.gz | |
cargo fmt
Diffstat (limited to 'mumd/src/command.rs')
| -rw-r--r-- | mumd/src/command.rs | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/mumd/src/command.rs b/mumd/src/command.rs index 5407ea3..d4b25d0 100644 --- a/mumd/src/command.rs +++ b/mumd/src/command.rs @@ -1,11 +1,11 @@ use crate::state::State; +use crate::network::tcp::{TcpEvent, TcpEventCallback}; use ipc_channel::ipc::IpcSender; use log::*; use mumlib::command::{Command, CommandResponse}; use std::sync::{Arc, Mutex}; use tokio::sync::{mpsc, oneshot}; -use crate::network::tcp::{TcpEvent, TcpEventCallback}; pub async fn handle( state: Arc<Mutex<State>>, @@ -24,11 +24,14 @@ pub async fn handle( if let Some(event) = event { let (tx, rx) = oneshot::channel(); //TODO handle this error - let _ = tcp_event_register_sender.send((event, Box::new(move |e| { - let response = generator(Some(e)); - response_sender.send(response).unwrap(); - tx.send(()).unwrap(); - }))); + let _ = tcp_event_register_sender.send(( + event, + Box::new(move |e| { + let response = generator(Some(e)); + response_sender.send(response).unwrap(); + tx.send(()).unwrap(); + }), + )); rx.await.unwrap(); } else { |
