mirror of
https://github.com/feschber/lan-mouse.git
synced 2026-04-17 00:01:27 +03:00
remove unneccessary enumerate request
This commit is contained in:
@@ -417,26 +417,6 @@ impl Server {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
// initial sync of clients
|
|
||||||
frontend_tx.send(FrontendEvent::Enumerate()).await?;
|
|
||||||
let active = self
|
|
||||||
.client_manager
|
|
||||||
.borrow()
|
|
||||||
.get_client_states()
|
|
||||||
.filter_map(|s| {
|
|
||||||
if s.active {
|
|
||||||
Some(s.client.handle)
|
|
||||||
} else {
|
|
||||||
None
|
|
||||||
}
|
|
||||||
})
|
|
||||||
.collect::<Vec<_>>();
|
|
||||||
for client in active {
|
|
||||||
frontend_tx
|
|
||||||
.send(FrontendEvent::ActivateClient(client, true))
|
|
||||||
.await?;
|
|
||||||
}
|
|
||||||
|
|
||||||
tokio::select! {
|
tokio::select! {
|
||||||
_ = signal::ctrl_c() => {
|
_ = signal::ctrl_c() => {
|
||||||
log::info!("terminating service");
|
log::info!("terminating service");
|
||||||
@@ -862,6 +842,7 @@ impl Server {
|
|||||||
|
|
||||||
let tx = frontend_tx.clone();
|
let tx = frontend_tx.clone();
|
||||||
tokio::task::spawn_local(async move {
|
tokio::task::spawn_local(async move {
|
||||||
|
let _ = tx.send(FrontendEvent::Enumerate()).await;
|
||||||
loop {
|
loop {
|
||||||
let event = frontend::read_event(&mut stream).await;
|
let event = frontend::read_event(&mut stream).await;
|
||||||
match event {
|
match event {
|
||||||
|
|||||||
Reference in New Issue
Block a user