diff --git a/src/peer.rs b/src/peer.rs index f193429..b19c705 100644 --- a/src/peer.rs +++ b/src/peer.rs @@ -139,7 +139,10 @@ where I: Stream + Send, } } } - None => running = false, + None => { + tracing::trace!("remote has closed"); + running = false; + } }, msgopt = self.rx.recv().boxed().fuse() => { let mut ok = true;