From bab9049cb060e7cbc9c778ddb3a6b5f95ba31094 Mon Sep 17 00:00:00 2001 From: Zhengchao An Date: Wed, 26 Aug 2026 10:50:49 +0800 Subject: [PATCH] fix(ci): clear remaining merged main Clippy lints (#6616) --- rustfs/src/app/object_usecase.rs | 5 ++--- rustfs/src/connect/client.rs | 8 +++++--- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/rustfs/src/app/object_usecase.rs b/rustfs/src/app/object_usecase.rs index 10665335b..bda5d23d6 100644 --- a/rustfs/src/app/object_usecase.rs +++ b/rustfs/src/app/object_usecase.rs @@ -3275,9 +3275,8 @@ fn successful_delete_audit_objects( .objects .iter() .zip(successful_results) - .filter_map(|(requested, successful)| { - successful.then(|| AuditObjectVersion::new(requested.key.clone(), requested.version_id.clone())) - }) + .filter(|(_, successful)| *successful) + .map(|(requested, _)| AuditObjectVersion::new(requested.key.clone(), requested.version_id.clone())) .collect() } diff --git a/rustfs/src/connect/client.rs b/rustfs/src/connect/client.rs index 39191c7ca..114f1d742 100644 --- a/rustfs/src/connect/client.rs +++ b/rustfs/src/connect/client.rs @@ -64,7 +64,7 @@ pub(crate) enum RotationAttempt { } enum SingleRequest { - Response(CredentialResponse), + Response(Box), Unavailable { status: Option, retry_after: Option, @@ -329,7 +329,7 @@ impl ConnectClient { let path = format!("clusterDevices/{}:rotateCredential", credential.uid); let url = self.url(&path)?; let response = match self.send_once(StatusCode::OK, client.post(url).json(&body)).await? { - SingleRequest::Response(response) => response, + SingleRequest::Response(response) => *response, SingleRequest::Unavailable { status, retry_after } => { return Ok(RotationAttempt::Unavailable { status, retry_after }); } @@ -520,7 +520,9 @@ impl ConnectClient { }; let status = response.status(); if status == success { - return decode_response(response).await.map(SingleRequest::Response); + return decode_response(response) + .await + .map(|response| SingleRequest::Response(Box::new(response))); } if matches!(status, StatusCode::UNAUTHORIZED | StatusCode::FORBIDDEN) { let reason = decode_reason(response).await;