diff options
| author | Eskil Queseth <eskilq@kth.se> | 2021-05-19 02:11:53 +0200 |
|---|---|---|
| committer | Eskil Queseth <eskilq@kth.se> | 2021-05-19 02:11:53 +0200 |
| commit | 0b2efad3e9aa569c27d339a5eca17c96155b4f9d (patch) | |
| tree | 21ee0b7cafe839e3764f339b5e9ba6c1653721da /mumd/src | |
| parent | f551de2bbc5e41c5cd76e36c2b0a6f10d9b4cddf (diff) | |
| download | mum-0b2efad3e9aa569c27d339a5eca17c96155b4f9d.tar.gz | |
remove await to parallellize better
Diffstat (limited to 'mumd/src')
| -rw-r--r-- | mumd/src/command.rs | 5 |
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(); |
