Fix cargo fmt formatting to pass CI

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: madeye

src/proxy.rs

@@ -21,9 +21,12 @@ use crate::ProxyBody;
 const TUNNEL_BUF_SIZE: usize = 128 * 1024;
 
 /// Global pooled HTTP/1.1 client for forward proxying (non-TFO path).
-static POOLED_CLIENT: std::sync::OnceLock<Client<hyper_util::client::legacy::connect::HttpConnector, Incoming>> = std::sync::OnceLock::new();
+static POOLED_CLIENT: std::sync::OnceLock<
+    Client<hyper_util::client::legacy::connect::HttpConnector, Incoming>,
+> = std::sync::OnceLock::new();
 
-fn get_pooled_client() -> &'static Client<hyper_util::client::legacy::connect::HttpConnector, Incoming> {
+fn get_pooled_client(
+) -> &'static Client<hyper_util::client::legacy::connect::HttpConnector, Incoming> {
     POOLED_CLIENT.get_or_init(|| {
         Client::builder(TokioExecutor::new())
             .pool_idle_timeout(std::time::Duration::from_secs(90))
@@ -66,8 +69,13 @@ pub async fn handle_connect(
                 let mut client = TokioIo::new(upgraded);
                 match net::connect(&addr, fast_open).await {
                     Ok(mut target) => {
-                        if let Err(e) =
-                            tokio::io::copy_bidirectional_with_sizes(&mut client, &mut target, TUNNEL_BUF_SIZE, TUNNEL_BUF_SIZE).await
+                        if let Err(e) = tokio::io::copy_bidirectional_with_sizes(
+                            &mut client,
+                            &mut target,
+                            TUNNEL_BUF_SIZE,
+                            TUNNEL_BUF_SIZE,
+                        )
+                        .await
                         {
                             error!("tunnel {addr} io error: {e}");
                         }
@@ -161,10 +169,7 @@ pub async fn handle_forward(
     } else {
         // Pooled client path: connection reuse, automatic URI handling
         let client = get_pooled_client();
-        let resp = client
-            .request(req)
-            .await
-            .context("pooled client request")?;
+        let resp = client.request(req).await.context("pooled client request")?;
 
         let (parts, body) = resp.into_parts();
         Ok(Response::from_parts(parts, Either::Right(body)))

tests/throughput_tests.rs

@@ -20,8 +20,7 @@ async fn test_connect_tunnel_throughput() {
     let data = DataServer::start(CONNECT_SIZE).await;
     let server = TestServer::start_no_auth().await;
 
-    let proxy = reqwest::Proxy::all(server.proxy_url())
-        .unwrap();
+    let proxy = reqwest::Proxy::all(server.proxy_url()).unwrap();
 
     let ca_cert = reqwest::tls::Certificate::from_pem(server.ca_pem.as_bytes()).unwrap();
 
@@ -34,7 +33,14 @@ async fn test_connect_tunnel_throughput() {
     let url = format!("http://127.0.0.1:{}/data", data.addr.port());
 
     // Warm up
-    let _ = client.get(&url).send().await.unwrap().bytes().await.unwrap();
+    let _ = client
+        .get(&url)
+        .send()
+        .await
+        .unwrap()
+        .bytes()
+        .await
+        .unwrap();
 
     let start = Instant::now();
     let resp = client.get(&url).send().await.unwrap();
@@ -61,8 +67,7 @@ async fn test_http_forward_throughput() {
     let data = DataServer::start(FORWARD_SIZE).await;
     let server = TestServer::start_no_auth().await;
 
-    let proxy = reqwest::Proxy::http(server.proxy_url())
-        .unwrap();
+    let proxy = reqwest::Proxy::http(server.proxy_url()).unwrap();
 
     let ca_cert = reqwest::tls::Certificate::from_pem(server.ca_pem.as_bytes()).unwrap();
 
@@ -75,7 +80,14 @@ async fn test_http_forward_throughput() {
     let url = format!("http://127.0.0.1:{}/data", data.addr.port());
 
     // Warm up
-    let _ = client.get(&url).send().await.unwrap().bytes().await.unwrap();
+    let _ = client
+        .get(&url)
+        .send()
+        .await
+        .unwrap()
+        .bytes()
+        .await
+        .unwrap();
 
     let start = Instant::now();
     let resp = client.get(&url).send().await.unwrap();
@@ -102,8 +114,7 @@ async fn test_http_forward_request_rate() {
     let echo = EchoServer::start().await;
     let server = TestServer::start_no_auth().await;
 
-    let proxy = reqwest::Proxy::http(server.proxy_url())
-        .unwrap();
+    let proxy = reqwest::Proxy::http(server.proxy_url()).unwrap();
 
     let ca_cert = reqwest::tls::Certificate::from_pem(server.ca_pem.as_bytes()).unwrap();
 
@@ -116,7 +127,14 @@ async fn test_http_forward_request_rate() {
     let url = format!("http://127.0.0.1:{}/ping", echo.addr.port());
 
     // Warm up
-    let _ = client.get(&url).send().await.unwrap().bytes().await.unwrap();
+    let _ = client
+        .get(&url)
+        .send()
+        .await
+        .unwrap()
+        .bytes()
+        .await
+        .unwrap();
 
     let start = Instant::now();
     for _ in 0..REQUEST_COUNT {