From 5c0abab1b7bf0f2858c451d6f0efc7ca0e138fc6 Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Sat, 29 Jun 2024 21:16:46 +0200
Subject: use shadown variables to name clones and place them between {} when
 spawning new tasks

---
 p2p/src/listener.rs | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

(limited to 'p2p/src/listener.rs')

diff --git a/p2p/src/listener.rs b/p2p/src/listener.rs
index 923eb18..8a5deaa 100644
--- a/p2p/src/listener.rs
+++ b/p2p/src/listener.rs
@@ -87,9 +87,13 @@ impl Listener {
 
         info!("Start listening on {resolved_endpoint}");
 
-        let selfc = self.clone();
-        self.task_group
-            .spawn(selfc.listen_loop(listener, callback), |_| async {});
+        self.task_group.spawn(
+            {
+                let this = self.clone();
+                async move { this.listen_loop(listener, callback).await }
+            },
+            |_| async {},
+        );
         Ok(resolved_endpoint)
     }
 
@@ -135,16 +139,15 @@ impl Listener {
 
             self.connection_slots.add();
 
-            let selfc = self.clone();
-            let on_disconnect = |res| async move {
-                if let TaskResult::Completed(Err(err)) = res {
-                    debug!("Inbound connection dropped: {err}");
+            let on_disconnect = {
+                let this = self.clone();
+                |res| async move {
+                    if let TaskResult::Completed(Err(err)) = res {
+                        debug!("Inbound connection dropped: {err}");
+                    }
+                    this.monitor.notify(ConnEvent::Disconnected(endpoint)).await;
+                    this.connection_slots.remove().await;
                 }
-                selfc
-                    .monitor
-                    .notify(ConnEvent::Disconnected(endpoint))
-                    .await;
-                selfc.connection_slots.remove().await;
             };
 
             let callback = callback.clone();
-- 
cgit v1.2.3