diff --git a/gossipsub.go b/gossipsub.go
index 7bb2330..43a82ca 100644
--- a/gossipsub.go
+++ b/gossipsub.go
@@ -383,7 +383,12 @@ func (gs *GossipSubRouter) addBackoff(p peer.ID, topic string) {
 }
 
 func (gs *GossipSubRouter) pxConnect(peers []*pb.PeerInfo) {
+	if len(peers) > GossipSubPrunePeers {
+		peers = peers[:GossipSubPrunePeers]
+	}
+
 	toconnect := make([]connectInfo, 0, len(peers))
+
 	for _, pi := range peers {
 		p := peer.ID(pi.PeerID)