methanium/mtp
Watch
3
0
Fork
You've already forked mtp
 0
Code Issues Pull requests 3 Projects Releases 22 Packages Wiki Activity Actions

(fix): formatting
Some checks failed
CI / checks (push) Failing after 2m20s
Details

Browse source
This commit is contained in:
Alois 2026-07-04 03:04:16 +02:00
commit 870b8002d2
1 changed files with 3 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
transport/src/connection.rs
View file

@ -139,9 +139,7 @@ impl Sender {
match timeout(policy.write_timeout, write_result).await { match timeout(policy.write_timeout, write_result).await {
Ok(Ok(())) => Ok(()), Ok(Ok(())) => Ok(()),
Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => { Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => {
log::warn!( log::warn!("[Sender] write failed: peer sent STOP_SENDING (error code {code})");
"[Sender] write failed: peer sent STOP_SENDING (error code {code})"
);
Err(CommunicationError::StreamClosed) Err(CommunicationError::StreamClosed)
} }
Ok(Err(other)) => { Ok(Err(other)) => {
@ -241,9 +239,7 @@ impl Sender {
match timeout(policy.write_timeout, stream.finish()).await { match timeout(policy.write_timeout, stream.finish()).await {
Ok(Ok(())) => Ok(()), Ok(Ok(())) => Ok(()),
Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => { Ok(Err(wtransport::error::StreamWriteError::Stopped(code))) => {
log::warn!( log::warn!("[Sender] finish failed: peer sent STOP_SENDING (error code {code})");
"[Sender] finish failed: peer sent STOP_SENDING (error code {code})"
);
Err(CommunicationError::StreamClosed) Err(CommunicationError::StreamClosed)
} }
Ok(Err(other)) => { Ok(Err(other)) => {
@ -256,6 +252,7 @@ impl Sender {
} }
} }
} }
async fn send_close_frame( async fn send_close_frame(
conn: &Connection, conn: &Connection,
policy: &Policy, policy: &Policy,