diff --git a/iroh-gossip/src/net.rs b/iroh-gossip/src/net.rs index fc81efd928..3aeb5dc28e 100644 --- a/iroh-gossip/src/net.rs +++ b/iroh-gossip/src/net.rs @@ -384,7 +384,7 @@ impl Actor { Some(res) = self.conn_manager.next() => { trace!(?i, "tick: conn_manager"); match res { - Ok(conn) => self.handle_new_connection(conn).await, + Ok(conn) => self.handle_new_connection(conn), Err(err) => { self.handle_in_event(InEvent::PeerDisconnected(err.node_id), Instant::now()).await?; } @@ -545,7 +545,7 @@ impl Actor { Ok(()) } - async fn handle_new_connection(&mut self, new_conn: ConnInfo) { + fn handle_new_connection(&mut self, new_conn: ConnInfo) { let ConnInfo { conn, node_id, diff --git a/iroh-net/src/conn_manager.rs b/iroh-net/src/conn_manager.rs index 418b3ab133..43e5cf3b69 100644 --- a/iroh-net/src/conn_manager.rs +++ b/iroh-net/src/conn_manager.rs @@ -440,9 +440,6 @@ mod tests { } tasks.abort_all(); - while let Some(r) = tasks.join_next().await { - assert!(r.unwrap_err().is_cancelled()); - } Ok(()) }