diff --git a/iroh-relay/src/server/client.rs b/iroh-relay/src/server/client.rs index b7d8c30784..e5f505cc9a 100644 --- a/iroh-relay/src/server/client.rs +++ b/iroh-relay/src/server/client.rs @@ -300,8 +300,7 @@ impl Actor { let frame = match maybe_frame { Some(frame) => frame?, None => { - tracing::trace!("stream terminated"); - return Ok(()); + anyhow::bail!("stream terminated"); } }; match frame { diff --git a/iroh/src/endpoint.rs b/iroh/src/endpoint.rs index 02493efafd..f4ae2d46f0 100644 --- a/iroh/src/endpoint.rs +++ b/iroh/src/endpoint.rs @@ -1663,6 +1663,7 @@ mod tests { send.finish().unwrap(); send.stopped().await.unwrap(); recv.read_to_end(0).await.unwrap(); + conn.close(0u16.into(), b""); info!(%i, peer = %peer_id.fmt_short(), "finished"); info!("[server] round {i} done in {:?}", round_start.elapsed()); }