1 files changed, 4 insertions, 0 deletions
diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index a936fa2..3ceea3c 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -492,6 +492,10 @@ pub(crate) async fn run_peer_worker(state: AppState) {
             apply_forget_records(&state).await;
             crate::swarm::members::ensure_registered(&state).await;
             crate::swarm::stability::tick(&state).await;
+            {
+                let known = state.peer_states.read().await;
+                state.traffic.retain(|peer| known.contains_key(peer));
+            }
             if let Some(change) = topology::refresh(&state).await {
                 apply_neighbour_change(&state, change).await;
             }