aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/command.rs
diff options
context:
space:
mode:
authorEskil <eskilq@kth.se>2020-10-16 02:36:13 +0200
committerEskil <eskilq@kth.se>2020-10-16 02:36:13 +0200
commit27d8b16b40a5f5a0633c2e54640999d4e6cdd9a3 (patch)
tree769971b8921aa2c0d5c2845323a898f1603cfebe /mumd/src/command.rs
parent18a3c0b3cf8254b70857e31ddd2b6213b10db156 (diff)
parentd15a4adb457b8caab4e76baff8e27ade347a275d (diff)
downloadmum-27d8b16b40a5f5a0633c2e54640999d4e6cdd9a3.tar.gz
Merge branch 'error-handling' into 'main'
Error handling Closes #13 See merge request gustav/mum!3
Diffstat (limited to 'mumd/src/command.rs')
-rw-r--r--mumd/src/command.rs6
1 files changed, 2 insertions, 4 deletions
diff --git a/mumd/src/command.rs b/mumd/src/command.rs
index 9adf7d8..57eaaa3 100644
--- a/mumd/src/command.rs
+++ b/mumd/src/command.rs
@@ -8,12 +8,10 @@ use tokio::sync::mpsc;
pub async fn handle(
state: Arc<Mutex<State>>,
- mut command_receiver: mpsc::UnboundedReceiver<(Command, IpcSender<Result<Option<CommandResponse>, ()>>)>,
+ mut command_receiver: mpsc::UnboundedReceiver<(Command, IpcSender<mumlib::error::Result<Option<CommandResponse>>>)>,
) {
debug!("Begin listening for commands");
- loop {
- debug!("Enter loop");
- let command = command_receiver.recv().await.unwrap();
+ while let Some(command) = command_receiver.recv().await {
debug!("Received command {:?}", command.0);
let mut state = state.lock().unwrap();
let (wait_for_connected, command_response) = state.handle_command(command.0).await;