diff --git a/libp2p/protocols/pubsub/gossipsub/behavior.nim b/libp2p/protocols/pubsub/gossipsub/behavior.nim index 302695abf..d7c793204 100644 --- a/libp2p/protocols/pubsub/gossipsub/behavior.nim +++ b/libp2p/protocols/pubsub/gossipsub/behavior.nim @@ -663,6 +663,7 @@ proc onHeartbeat(g: GossipSub) {.raises: [].} = g.pruned(peer, t) g.mesh.removePeer(t, peer) prunes &= peer + peer.clearNonPriorityQueue() if prunes.len > 0: let prune = RPCMsg(control: some(ControlMessage( prune: @[ControlPrune(