limit the number of hosts read from each pong

This commit is contained in:
Zlatin Balevsky
2020-09-17 16:19:48 +01:00
parent 20aac03789
commit b18772465c

View File

@ -177,7 +177,7 @@ abstract class Connection implements Closeable {
lastPongReceivedTime = System.currentTimeMillis()
if (pong.pongs == null)
throw new Exception("Pong doesn't have pongs")
pong.pongs.each {
pong.pongs.stream().limit(10).forEach {
def dest = new Destination(it)
eventBus.publish(new HostDiscoveredEvent(destination: dest))
}