fix(acp-nats): replace unimplemented!() in session_update test mock

Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>

Author: yordis

rsworkspace/crates/acp-nats/src/client/mod.rs

@@ -67,8 +67,15 @@ pub async fn run<
     let max_concurrent = bridge.config.max_concurrent_client_tasks();
 
     while let Some(msg) = subscriber.next().await {
-        process_message(msg, &nats, client.clone(), bridge.clone(), &in_flight, max_concurrent)
-            .await;
+        process_message(
+            msg,
+            &nats,
+            client.clone(),
+            bridge.clone(),
+            &in_flight,
+            max_concurrent,
+        )
+        .await;
     }
 
     info!("Client proxy subscriber ended");
@@ -127,8 +134,7 @@ async fn process_message<
         if let Some(reply_to) = msg.reply.as_ref().map(|reply| reply.to_string()) {
             let bytes = error_response_bytes(
                 request_id,
-                Error::internal_error()
-                    .data("Bridge overloaded - too many concurrent requests"),
+                Error::internal_error().data("Bridge overloaded - too many concurrent requests"),
             );
             let headers = headers_with_trace_context();
             if let Err(e) = nats.publish_with_headers(reply_to, headers, bytes).await {
@@ -249,9 +255,7 @@ mod tests {
         }
     }
 
-    fn make_bridge(
-        nats: MockNatsClient,
-    ) -> Rc<Bridge<MockNatsClient, SystemClock>> {
+    fn make_bridge(nats: MockNatsClient) -> Rc<Bridge<MockNatsClient, SystemClock>> {
         Rc::new(Bridge::new(
             nats,
             SystemClock,