From 6d2e56e7c8cd2b23838b49e7df1f14088b0545f1 Mon Sep 17 00:00:00 2001 From: damocles Date: Sun, 5 Jul 2026 12:00:18 +0200 Subject: [PATCH] fix formatting (treefmt) --- hive-ag3nt/src/bin/hive.rs | 7 ++----- hive-c0re/src/broker.rs | 4 +--- 2 files changed, 3 insertions(+), 8 deletions(-) diff --git a/hive-ag3nt/src/bin/hive.rs b/hive-ag3nt/src/bin/hive.rs index 0a09c101..967ff414 100644 --- a/hive-ag3nt/src/bin/hive.rs +++ b/hive-ag3nt/src/bin/hive.rs @@ -389,11 +389,8 @@ impl Surface for AgentSurface { } async fn wake_external(socket: &Path, from: String, body: String) -> Result<()> { - let resp: AgentResponse = client::request( - socket, - &AgentRequest::Wake { from, body }, - ) - .await?; + let resp: AgentResponse = + client::request(socket, &AgentRequest::Wake { from, body }).await?; match resp { AgentResponse::Ok => Ok(()), AgentResponse::Err { message } => anyhow::bail!("wake: {message}"), diff --git a/hive-c0re/src/broker.rs b/hive-c0re/src/broker.rs index 6a21a7e9..c80d1ef4 100644 --- a/hive-c0re/src/broker.rs +++ b/hive-c0re/src/broker.rs @@ -1453,9 +1453,7 @@ mod tests { let h = open_broker(); let broker = &h.broker; broker.send(&msg("a", "b", "mail")).unwrap(); - broker - .send(&msg("matrix", "b", "matrix wake")) - .unwrap(); + broker.send(&msg("matrix", "b", "matrix wake")).unwrap(); let batch = broker.recv_batch("b", 10).unwrap(); assert_eq!(batch.len(), 2); // FIFO: mail was inserted first, comes out first.