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.