From 5df6812dd2254b871eb773dc626b89646ca87495 Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Wed, 22 May 2024 18:02:51 +0200
Subject: p2p: monitor system use core::EventSys instead of pubsub pattern

---
 p2p/src/peer_pool.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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

diff --git a/p2p/src/peer_pool.rs b/p2p/src/peer_pool.rs
index 8b16ef5..07bb73d 100644
--- a/p2p/src/peer_pool.rs
+++ b/p2p/src/peer_pool.rs
@@ -193,7 +193,7 @@ impl PeerPool {
         info!("Add new peer {pid}, direction: {conn_direction}, endpoint: {endpoint}");
 
         self.monitor
-            .notify(&PeerPoolEvent::NewPeer(pid.clone()).into())
+            .notify(PeerPoolEvent::NewPeer(pid.clone()))
             .await;
 
         Ok(())
@@ -216,7 +216,7 @@ impl PeerPool {
         peer.shutdown().await;
 
         self.monitor
-            .notify(&PeerPoolEvent::RemovePeer(pid.clone()).into())
+            .notify(PeerPoolEvent::RemovePeer(pid.clone()))
             .await;
 
         let endpoint = peer.remote_endpoint();
-- 
cgit v1.2.3