diff options
| author | hozan23 <hozan23@karyontech.net> | 2024-05-22 18:02:51 +0200 |
|---|---|---|
| committer | hozan23 <hozan23@karyontech.net> | 2024-05-22 18:02:51 +0200 |
| commit | 5df6812dd2254b871eb773dc626b89646ca87495 (patch) | |
| tree | 18828be9c86aba205d30086f705f2c6e2aeee975 /p2p/src/peer_pool.rs | |
| parent | c2860d3266aa1233787400b163d527fdc7dafe61 (diff) | |
p2p: monitor system use core::EventSys instead of pubsub pattern
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(); |