From b62540d9bea86bf497ab98da3376f8ebaa738e30 Mon Sep 17 00:00:00 2001 From: Ferdinand Schober Date: Thu, 5 Sep 2024 10:37:49 +0200 Subject: [PATCH] asdf --- src/server/network_task.rs | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/src/server/network_task.rs b/src/server/network_task.rs index 1ab486e..ec00706 100644 --- a/src/server/network_task.rs +++ b/src/server/network_task.rs @@ -29,15 +29,13 @@ pub(crate) async fn new( Ok(spawn_local(async move { let sender_rx = Rc::new(RefCell::new(udp_send_rx)); - loop { - let udp_receiver = spawn_local(listen_dtls(listen_addr, udp_recv_tx.clone())); - let udp_sender = spawn_local(udp_sender(sender_rx.clone())); - log::info!("starting sender + receiver"); - tokio::select! { - e = udp_receiver => panic!("{e:?}"), /* channel closed */ - _ = udp_sender => break, /* channel closed */ - _ = server.cancelled() => break, /* cancellation requested */ - } + let udp_receiver = spawn_local(listen_dtls(listen_addr, udp_recv_tx.clone())); + let udp_sender = spawn_local(udp_sender(sender_rx.clone())); + log::info!("starting sender + receiver"); + tokio::select! { + e = udp_receiver => panic!("{e:?}"), /* channel closed */ + _ = udp_sender => {}, /* channel closed */ + _ = server.cancelled() => {}, /* cancellation requested */ } })) }