aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/command.rs
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2020-10-29 21:28:12 +0100
committerGustav Sörnäs <gustav@sornas.net>2020-10-29 21:28:12 +0100
commit4010e0f5abb28bae3207c78dba74f0896eedea51 (patch)
tree2e1c215705d04f86e47a1a0a9015dfd6ed6feeaf /mumd/src/command.rs
parent3e7e375e65760a03b6692106ab0ed806ca65e470 (diff)
downloadmum-4010e0f5abb28bae3207c78dba74f0896eedea51.tar.gz
cargo fmt
Diffstat (limited to 'mumd/src/command.rs')
-rw-r--r--mumd/src/command.rs15
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 {