diff options
Diffstat (limited to 'p2p/src/peer_pool.rs')
| -rw-r--r-- | p2p/src/peer_pool.rs | 4 |
1 files changed, 2 insertions, 2 deletions
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(); |