graham/towerops-agent
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix clippy error

Browse source
This commit is contained in:
Graham McIntire 2026-01-30 16:00:33 -06:00
parent 380beaca1a
commit c3e6e8c5b0
No known key found for this signature in database
1 changed files with 4 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/websocket_client.rs
View file

@ -122,7 +122,7 @@ impl AgentClient {
pub async fn run(&mut self, mut shutdown_rx: watch::Receiver<bool>) -> Result<()> { pub async fn run(&mut self, mut shutdown_rx: watch::Receiver<bool>) -> Result<()> {
let mut heartbeat_interval = interval(Duration::from_secs(60)); let mut heartbeat_interval = interval(Duration::from_secs(60));
let result = loop { loop {
tokio::select! { tokio::select! {
// Check for shutdown signal (highest priority) // Check for shutdown signal (highest priority)
_ = shutdown_rx.changed() => { _ = shutdown_rx.changed() => {
@ -166,8 +166,8 @@ impl AgentClient {
} }
// Receive SNMP results from job tasks // Receive SNMP results from job tasks
Some(result) = self.result_rx.recv() => { Some(snmp_result) = self.result_rx.recv() => {
if let Err(e) = self.send_result(result).await { if let Err(e) = self.send_result(snmp_result).await {
crate::log_error!("Error sending SNMP result: {}", e); crate::log_error!("Error sending SNMP result: {}", e);
} }
} }
@ -179,9 +179,7 @@ impl AgentClient {
} }
} }
} }
}; }
result
} }
/// Handle Phoenix channel message (JSON-wrapped). /// Handle Phoenix channel message (JSON-wrapped).