From aad301e083d0ed2306be6a0033b0b1fef06004ed Mon Sep 17 00:00:00 2001 From: Heikki Linnakangas Date: Tue, 29 Jul 2025 16:46:54 +0300 Subject: [PATCH] cargo fmt --- .../src/worker_process/control_socket.rs | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/pgxn/neon/communicator/src/worker_process/control_socket.rs b/pgxn/neon/communicator/src/worker_process/control_socket.rs index d74331943e..5e2b35de1e 100644 --- a/pgxn/neon/communicator/src/worker_process/control_socket.rs +++ b/pgxn/neon/communicator/src/worker_process/control_socket.rs @@ -30,8 +30,8 @@ use std::sync::Arc; use tokio::net::UnixListener; use crate::NEON_COMMUNICATOR_SOCKET_NAME; -use crate::worker_process::main_loop::CommunicatorWorkerProcessStruct; use crate::worker_process::lfc_metrics::LfcMetricsCollector; +use crate::worker_process::main_loop::CommunicatorWorkerProcessStruct; enum ControlSocketState<'a> { Full(&'a CommunicatorWorkerProcessStruct<'a>), @@ -147,12 +147,10 @@ async fn dump_cache_map(State(state): State>>) -> Res .body(Body::from(buf)) .unwrap() } - ControlSocketState::Legacy(_) => { - Response::builder() - .status(StatusCode::NOT_FOUND) - .header(CONTENT_TYPE, "application/text") - .body(Body::from(Vec::new())) - .unwrap() - } + ControlSocketState::Legacy(_) => Response::builder() + .status(StatusCode::NOT_FOUND) + .header(CONTENT_TYPE, "application/text") + .body(Body::from(Vec::new())) + .unwrap(), } }