diff --git a/crates/librqbit/src/peer_connection.rs b/crates/librqbit/src/peer_connection.rs index 4450d63..9a429bf 100644 --- a/crates/librqbit/src/peer_connection.rs +++ b/crates/librqbit/src/peer_connection.rs @@ -330,6 +330,7 @@ impl PeerConnection { full_len } WriterRequest::Disconnect => { + trace!("disconnect requested, closing writer"); return Ok(()); } }; @@ -378,10 +379,15 @@ impl PeerConnection { }; let r = tokio::select! { - r = reader => {r} - r = writer => {r} + r = reader => { + trace!("reader is done, exiting"); + r + } + r = writer => { + trace!("writer is done, exiting"); + r + } }; - trace!("either reader or writer are done, exiting"); r } }