mirror of
https://github.com/feschber/lan-mouse.git
synced 2026-04-20 02:53:20 +03:00
move assert to correct location
This commit is contained in:
@@ -218,19 +218,17 @@ impl Server {
|
|||||||
|
|
||||||
log::info!("terminating service");
|
log::info!("terminating service");
|
||||||
|
|
||||||
|
assert!(!capture_tx.is_closed());
|
||||||
|
assert!(!emulation_tx.is_closed());
|
||||||
|
assert!(!udp_recv_tx.is_closed());
|
||||||
|
assert!(!udp_send_tx.is_closed());
|
||||||
|
assert!(!request_tx.is_closed());
|
||||||
|
assert!(!dns_request.is_closed());
|
||||||
|
|
||||||
self.cancel();
|
self.cancel();
|
||||||
futures::future::join_all(join_handles).await;
|
futures::future::join_all(join_handles).await;
|
||||||
let _ = join!(capture, dns_task, emulation, network, ping);
|
let _ = join!(capture, dns_task, emulation, network, ping);
|
||||||
|
|
||||||
assert!(
|
|
||||||
!capture_tx.is_closed()
|
|
||||||
&& !emulation_tx.is_closed()
|
|
||||||
&& !udp_recv_tx.is_closed()
|
|
||||||
&& !udp_send_tx.is_closed()
|
|
||||||
&& !request_tx.is_closed()
|
|
||||||
&& !dns_request.is_closed()
|
|
||||||
);
|
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user