format

Author: benbrandt

src/agent-client-protocol-trace-viewer/src/lib.rs

@@ -36,7 +36,10 @@ pub struct TraceHandle {
 impl TraceHandle {
     /// Push a new event to the trace.
     pub fn push(&self, event: serde_json::Value) {
-        self.events.lock().expect("events mutex poisoned").push(event);
+        self.events
+            .lock()
+            .expect("events mutex poisoned")
+            .push(event);
     }
 
     /// Get the current number of events.
@@ -48,7 +51,10 @@ impl TraceHandle {
     /// Check if empty.
     #[must_use]
     pub fn is_empty(&self) -> bool {
-        self.events.lock().expect("events mutex poisoned").is_empty()
+        self.events
+            .lock()
+            .expect("events mutex poisoned")
+            .is_empty()
     }
 }
 

src/agent-client-protocol/examples/simple_agent.rs

@@ -20,7 +20,10 @@ async fn main() -> Result<()> {
         .on_receive_dispatch(
             async move |message: Dispatch, cx: ConnectionTo<Client>| {
                 // Respond to any other message with an error
-                message.respond_with_error(agent_client_protocol::util::internal_error("unhandled message"), cx)
+                message.respond_with_error(
+                    agent_client_protocol::util::internal_error("unhandled message"),
+                    cx,
+                )
             },
             agent_client_protocol::on_receive_dispatch!(),
         )

src/agent-client-protocol/tests/jsonrpc_error_handling.rs

@@ -220,7 +220,10 @@ async fn test_incomplete_line() {
     let result = connection.connect_to(transport).await;
 
     // Server should terminate cleanly (not hang) when EOF is hit mid-message
-    assert!(result.is_ok(), "expected clean shutdown on EOF, got: {result:?}");
+    assert!(
+        result.is_ok(),
+        "expected clean shutdown on EOF, got: {result:?}"
+    );
 }
 
 // ============================================================================