refactor: remove &mut from Endpoint::disconnect_from

src/connection_pool.rs

@@ -53,7 +53,7 @@ impl ConnectionPool {
             .is_some()
     }
 
-    pub fn remove(&mut self, addr: &SocketAddr) -> Vec<quinn::Connection> {
+    pub fn remove(&self, addr: &SocketAddr) -> Vec<quinn::Connection> {
         let mut store = self.store.lock().unwrap_or_else(PoisonError::into_inner);
 
         let keys_to_remove = store

src/endpoint.rs

@@ -271,7 +271,7 @@ impl Endpoint {
     }
 
     /// Removes all existing connections to a given peer
-    pub fn disconnect_from(&mut self, peer_addr: &SocketAddr) -> Result<()> {
+    pub fn disconnect_from(&self, peer_addr: &SocketAddr) -> Result<()> {
         self.connection_pool
             .remove(peer_addr)
             .iter()

src/tests/common.rs

@@ -173,7 +173,7 @@ async fn disconnection() -> Result<()> {
     utils::init_logging();
 
     let qp2p = new_qp2p()?;
-    let (mut alice, mut alice_incoming_connections, _, mut alice_disconnections) =
+    let (alice, mut alice_incoming_connections, _, mut alice_disconnections) =
         qp2p.new_endpoint().await?;
     let alice_addr = alice.socket_addr();
 
@@ -234,7 +234,7 @@ async fn simultaneous_incoming_and_outgoing_connections() -> Result<()> {
     ) = qp2p.new_endpoint().await?;
     let alice_addr = alice.socket_addr();
 
-    let (mut bob, mut bob_incoming_connections, mut bob_incoming_messages, _) =
+    let (bob, mut bob_incoming_connections, mut bob_incoming_messages, _) =
         qp2p.new_endpoint().await?;
     let bob_addr = bob.socket_addr();