TheLanc3/lan-mouse
1
0
Fork 0
mirror of https://github.com/feschber/lan-mouse.git synced 2026-04-13 01:51:27 +03:00
Code Issues Packages Projects Releases Wiki Activity

asdf

Browse Source
This commit is contained in:
Ferdinand Schober
2024-09-05 10:37:49 +02:00
parent 90561744a0
commit b62540d9be
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/server/network_task.rs
View File

@@ -29,15 +29,13 @@ pub(crate) async fn new(
Ok(spawn_local(async move { Ok(spawn_local(async move {
let sender_rx = Rc::new(RefCell::new(udp_send_rx)); 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_receiver = spawn_local(listen_dtls(listen_addr, udp_recv_tx.clone())); let udp_sender = spawn_local(udp_sender(sender_rx.clone()));
let udp_sender = spawn_local(udp_sender(sender_rx.clone())); log::info!("starting sender + receiver");
log::info!("starting sender + receiver"); tokio::select! {
tokio::select! { e = udp_receiver => panic!("{e:?}"), /* channel closed */
e = udp_receiver => panic!("{e:?}"), /* channel closed */ _ = udp_sender => {}, /* channel closed */
_ = udp_sender => break, /* channel closed */ _ = server.cancelled() => {}, /* cancellation requested */
_ = server.cancelled() => break, /* cancellation requested */
}
} }
})) }))
} }