vinzenz/hyperhive
vinzenz/hyperhive
Watch
0
0
Fork
You've already forked hyperhive
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix formatting (treefmt)

Browse source
This commit is contained in:
damocles 2026-07-05 12:00:18 +02:00
commit 6d2e56e7c8
2 changed files with 3 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

7
hive-ag3nt/src/bin/hive.rs
View file

@ -389,11 +389,8 @@ impl Surface for AgentSurface {
} }
async fn wake_external(socket: &Path, from: String, body: String) -> Result<()> { async fn wake_external(socket: &Path, from: String, body: String) -> Result<()> {
let resp: AgentResponse = client::request( let resp: AgentResponse =
socket, client::request(socket, &AgentRequest::Wake { from, body }).await?;
&AgentRequest::Wake { from, body },
)
.await?;
match resp { match resp {
AgentResponse::Ok => Ok(()), AgentResponse::Ok => Ok(()),
AgentResponse::Err { message } => anyhow::bail!("wake: {message}"), AgentResponse::Err { message } => anyhow::bail!("wake: {message}"),

4
hive-c0re/src/broker.rs
View file

@ -1453,9 +1453,7 @@ mod tests {
let h = open_broker(); let h = open_broker();
let broker = &h.broker; let broker = &h.broker;
broker.send(&msg("a", "b", "mail")).unwrap(); broker.send(&msg("a", "b", "mail")).unwrap();
broker broker.send(&msg("matrix", "b", "matrix wake")).unwrap();
.send(&msg("matrix", "b", "matrix wake"))
.unwrap();
let batch = broker.recv_batch("b", 10).unwrap(); let batch = broker.recv_batch("b", 10).unwrap();
assert_eq!(batch.len(), 2); assert_eq!(batch.len(), 2);
// FIFO: mail was inserted first, comes out first. // FIFO: mail was inserted first, comes out first.