From 870b8002d28a985babfd760f9d68ec1aff2f84cc Mon Sep 17 00:00:00 2001 From: Alois Date: Sat, 4 Jul 2026 03:04:16 +0200 Subject: [PATCH] (fix): formatting --- transport/src/connection.rs | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/transport/src/connection.rs b/transport/src/connection.rs index 653a822..b379008 100644 --- a/transport/src/connection.rs +++ b/transport/src/connection.rs @@ -139,9 +139,7 @@ impl Sender { match timeout(policy.write_timeout, write_result).await { Ok(Ok(())) => Ok(()), Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => { - log::warn!( - "[Sender] write failed: peer sent STOP_SENDING (error code {code})" - ); + log::warn!("[Sender] write failed: peer sent STOP_SENDING (error code {code})"); Err(CommunicationError::StreamClosed) } Ok(Err(other)) => { @@ -241,9 +239,7 @@ impl Sender { match timeout(policy.write_timeout, stream.finish()).await { Ok(Ok(())) => Ok(()), Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => { - log::warn!( - "[Sender] finish failed: peer sent STOP_SENDING (error code {code})" - ); + log::warn!("[Sender] finish failed: peer sent STOP_SENDING (error code {code})"); Err(CommunicationError::StreamClosed) } Ok(Err(other)) => { @@ -256,6 +252,7 @@ impl Sender { } } } + async fn send_close_frame( conn: &Connection, policy: &Policy,