aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src
diff options
context:
space:
mode:
authorEskil Queseth <eskilq@kth.se>2021-05-19 02:11:53 +0200
committerEskil Queseth <eskilq@kth.se>2021-05-19 02:11:53 +0200
commit0b2efad3e9aa569c27d339a5eca17c96155b4f9d (patch)
tree21ee0b7cafe839e3764f339b5e9ba6c1653721da /mumd/src
parentf551de2bbc5e41c5cd76e36c2b0a6f10d9b4cddf (diff)
downloadmum-0b2efad3e9aa569c27d339a5eca17c96155b4f9d.tar.gz
remove await to parallellize better
Diffstat (limited to 'mumd/src')
-rw-r--r--mumd/src/command.rs5
1 files changed, 0 insertions, 5 deletions
diff --git a/mumd/src/command.rs b/mumd/src/command.rs
index a62ddbd..d101104 100644
--- a/mumd/src/command.rs
+++ b/mumd/src/command.rs
@@ -27,18 +27,13 @@ pub async fn handle(
drop(state);
match event {
ExecutionContext::TcpEvent(event, generator) => {
- let (tx, rx) = oneshot::channel();
- //TODO handle this error
tcp_event_queue.register_callback(
event,
Box::new(move |e| {
let response = generator(e);
response_sender.send(response).unwrap();
- tx.send(()).unwrap();
}),
);
-
- rx.await.unwrap();
}
ExecutionContext::Now(generator) => {
response_sender.send(generator()).unwrap();