diff --git a/src/mavlink/manager.rs b/src/mavlink/manager.rs index 34f4932c..0337c26d 100644 --- a/src/mavlink/manager.rs +++ b/src/mavlink/manager.rs @@ -36,7 +36,7 @@ impl Default for Manager { let address = settings::manager::mavlink_endpoint().expect("No configured mavlink endpoint"); - let (sender, _receiver) = broadcast::channel(100); + let (sender, _receiver) = broadcast::channel(4000); let this = Self { connection: Arc::new(RwLock::new(Connection { @@ -74,7 +74,7 @@ impl Manager { fn receiver_loop(inner: Arc>) { loop { loop { - std::thread::sleep(std::time::Duration::from_millis(10)); + std::thread::sleep(std::time::Duration::from_millis(1)); let Ok(inner_guard) = inner.read() else { break; // Break to trigger reconnection