diff --git a/src/pub.rs b/src/pub.rs index 0db5d30..5b3fe95 100644 --- a/src/pub.rs +++ b/src/pub.rs @@ -154,6 +154,9 @@ impl MultiPeerBackend for PubSocketBackend { fn peer_disconnected(&self, peer_id: &PeerIdentity) { log::info!("Client disconnected {:?}", peer_id); + if let Some(monitor) = self.monitor().lock().as_mut() { + let _ = monitor.try_send(SocketEvent::Disconnected(peer_id.clone())); + } self.subscribers.remove(peer_id); } } diff --git a/src/sub.rs b/src/sub.rs index 72217dd..6bc7ea3 100644 --- a/src/sub.rs +++ b/src/sub.rs @@ -108,6 +108,9 @@ impl MultiPeerBackend for SubSocketBackend { } fn peer_disconnected(&self, peer_id: &PeerIdentity) { + if let Some(monitor) = self.monitor().lock().as_mut() { + let _ = monitor.try_send(SocketEvent::Disconnected(peer_id.clone())); + } self.peers.remove(peer_id); } }